slippinj.emr.job_flow package

Submodules

slippinj.emr.job_flow.configuration module

class slippinj.emr.job_flow.configuration.JobFlowConfigurationParser[source]

Bases: object

Given a configuration dict validate it and prepares to run a job flow

convert_to_arguments(configuration)[source]

Convert from the configuration dict to a valid dict to send as arguments to the AWS API :param configuration: dict :return: dict

validate(configuration)[source]

Validate if the given configuration has all the mandatory parameters configured :param configuration: dict :return: boolean

slippinj.emr.job_flow.run module

class slippinj.emr.job_flow.run.RunJobFlow(self_, *args, **kwargs)[source]

Bases: object

Run a job flow based on a given configuration

run_cluster(cluster_configuration)[source]

Launch a cluster based on given configuration :param cluster_configuration: string

Module contents