`airflow.providers.amazon.aws.operators.emr_terminate_job_flow`¶

Module Contents¶

class airflow.providers.amazon.aws.operators.emr_terminate_job_flow.EmrTerminateJobFlowOperator(*, job_flow_id: str, aws_conn_id: str = 'aws_default', **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Operator to terminate EMR JobFlows.

Parameters

job_flow_id (str) -- id of the JobFlow to terminate. (templated)
aws_conn_id (str) -- aws connection to uses

template_fields = ['job_flow_id'][source]¶

template_ext = [][source]¶

ui_color = #f9c915[source]¶

execute(self, context: Dict[str, Any])[source]¶

Was this entry helpful?