这确实有点令人困惑,而且没有很好的记录。
您已经在使用PythonOperator
。
现在只需添加选项
provide_context=True,
并使用指针扩展您的可调用对象,例如
update_bmk(bmk_code, is_hedged, **context)
现在,在您的函数中,您将可以访问有关任务的所有信息,包括执行日期,如下所示:
task_instance = context['task_instance']
execution_date = context['execution_date']
要查看上下文中项目的完整参考,请参阅https://airflow.apache.org/macros.html
这些是宏的文档,但是您可以使用上下文字典中的项目。