2024-04-25 09:05:28 发布
网友
当我们在气流中得到run_id时,如何获得时间戳(ts)?在
run_id
第一个: 在您的任务集中提供_context=True
bye_operator = PythonOperator( task_id='bye_task', python_callable=print_goodbye, provide_context=True, dag=dag )
第二: 确保将已知参数传递到回调函数:
第一个: 在您的任务集中提供_context=True
第二: 确保将已知参数传递到回调函数:
^{pr2}$相关问题 更多 >
编程相关推荐