python变量中的气流参考dag名称我有一个像下面这样的dag twomins = DAG( 'upsert_every_2mins', default_args=default_args, descriptio ...2024-06-28 已阅读: n次
气流:如何将BaseOperator执行的python脚本中的变量传递到DAG中的on_failure_callback arg我有一个简单的DAG与一个任务,需要停靠。基于该脚本的运行,其中包含variable1,我需要将其提供给在DAG文件中创建的回调函数。如何解决这个问题 with DAG( dag_id=Dag ...2024-06-28 已阅读: n次