airflow - Airflow 中的动态 schedule_interval

Question

我尝试在 Airflow 中运行动态 schedule_interval，如下所示。但只有当我手动运行 dag 时它才有效。你能帮我说一下，如果动态 schedule_interval 可能是一个原因，为什么 dag 没有自动运行或者还有其他原因吗？

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

谢谢!

Answer 1

您不应该像这样将 schedule_interval 设置为动态的，因为它会导致意外结果(如您所见)。

您似乎只想在星期一运行 DAG，对吗？如果是这种情况，那么您需要做的就是将 schedule_interval 设置为 00 07 * * 1，您不需要 if条件。