Loading airflow/docker/dags/utils/_utils.py +2 −2 Original line number Diff line number Diff line from airflow.providers.standard.operators.python import PythonOperator # from airflow.providers.standard.operators.python import PythonOperator # # # def get_run_id(**context): # # 从上下文中直接获取 dag_run_id Loading Loading
airflow/docker/dags/utils/_utils.py +2 −2 Original line number Diff line number Diff line from airflow.providers.standard.operators.python import PythonOperator # from airflow.providers.standard.operators.python import PythonOperator # # # def get_run_id(**context): # # 从上下文中直接获取 dag_run_id Loading