Module Contents

class*, cluster_id: str, step_concurrency_level: int, aws_conn_id: str = 'aws_default', **kwargs)[source]

Bases: airflow.models.BaseOperator

An operator that modifies an existing EMR cluster. :param cluster_id: cluster identifier :type cluster_id: str :param step_concurrency_level: Concurrency of the cluster :type step_concurrency_level: int :param aws_conn_id: aws connection to uses :type aws_conn_id: str :param do_xcom_push: if True, cluster_id is pushed to XCom with key cluster_id. :type do_xcom_push: bool

template_fields = ['cluster_id', 'step_concurrency_level'][source]
template_ext = [][source]
ui_color = #f9c915[source]
execute(self, context: Dict[str, Any])[source]

Was this entry helpful?