Airflow中的动态schedule_interval

2023-12-27

我尝试在 Airflow 中运行动态 Schedule_interval,如下所示。但它仅在我手动运行 dag 时才有效。您能否帮我说一下,如果动态 Schedule_interval 可能是一个原因,为什么 dag 不会自动运行,或者还有其他原因吗?

if datetime.today().day == 1:
    schedule_interval = '00 07 * * *'
else:
    schedule_interval = '00 07 * * 1'

谢谢你!


你不应该设置schedule_interval像这样充满活力,因为它可能会导致意想不到的结果(正如您所看到的)。

您似乎只在星期一尝试运行 DAG,是吗?如果是这种情况,那么您需要做的就是设置schedule_interval to 00 07 * * 1,你不需要if健康)状况。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Airflow中的动态schedule_interval 的相关文章

随机推荐