공부
[airflow] [emr_add_steps_operator] Allow job_flow_id & job_flow_name (Priority is in the order of id, name.)
승가비
2023. 5. 26. 21:38
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