티스토리 뷰

공부

[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
저작자표시 비영리

'공부' 카테고리의 다른 글

[tableau x athena] open port (athena, glue, sts) - 443, 444  (0) 2023.05.26
[python] dateutil parser weekday (Mon, Monday)  (0) 2023.05.26
[maven] scope  (0) 2023.05.26
[spark] 자주 쓰이는 config  (0) 2023.05.26
[slack] link <http://someurl|like this>  (0) 2023.05.26
댓글