티스토리 뷰

728x90
def __init__(
            self,
            job_flow_id=None,
            job_flow_name=None,
            cluster_states=None,
            aws_conn_id='aws_default',
            steps=None,
            *args, **kwargs):
        if not ((job_flow_id is None) ^ (job_flow_name is None)):
            raise AirflowException('Exactly one of job_flow_id or job_flow_name must be specified.')

allow args: `job_flow_id` & `job_flow_name`

 

https://github.com/apache/airflow/discussions/31314

 

[emr_add_steps_operator] Allow job_flow_id & job_flow_name (Priority is in the order of id, name.) · apache/airflow · Discussi

https://airflow.apache.org/docs/apache-airflow/1.10.12/_modules/airflow/contrib/operators/emr_add_steps_operator.html I make a emr_add_steps_operator. job_flow_id or job_flow_name exclusively exist...

github.com

 

728x90
댓글