airflow.contrib.operators.emr_terminate_job_flow_operator

Module Contents

class airflow.contrib.operators.emr_terminate_job_flow_operator.EmrTerminateJobFlowOperator(job_flow_id, aws_conn_id='s3_default', *args, **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)[source]

Was this entry helpful?