我有两个像这样定义的DAG
my_dag= DAG('my_dag_thu_and_friday',
catchup=False,
default_args=default_args,
schedule_interval='0 12,13,15,19 * * THU,FRI'
)
my_dag= DAG('my_dag_sat_and_sun',
catchup=False,
default_args=default_args,
schedule_interval='0 13,17 * * SAT,SUN'
)
它们运行相同的运算符和相同的代码,但只是根据是星期四/星期五还是星期六/星期日而按不同的时间表运行。是否有一种方法可以指定cron间隔,使我只有一个DAG有条件地处理调度
谢谢
没有清洁&清洁;然而,目前的简单解决方案AIP-39 Richer scheduler_interval将解决这个问题,因此在未来的版本中,这将变得很容易
目前,您的选择是:
'0 12,13,15,17,19 * * THU,FRI,SAT,SUN'
放置分支运算符来创建1个DAG,以确定是应该执行DummyOperator
还是您的运算符。例如,在THU
气流中运行17
将执行DummyOperator(因此不执行任何操作)李>相关问题 更多 >
编程相关推荐