指定日期和时间的完美作业调度



我想在prefect中为非cron和间隔安排作业,我有一些特定的日期,我想要流运行,我看到使用DateClocks可以在prefect 1中使用,但我没有看到任何示例,你能给我提供一个包括时区的吗?我想用代码来完成,而不是UI

我还没有尝试过,因为我是新的,我想设置运行的具体日期,你能给我一个例子,我们可以包括时区,以及?

是的,这是非常可行的-最简单的方法是利用pendulumrun_deployment实用程序:

import pendulum
from prefect.deployments import run_deployment
run_deployment(
name="flow/deploy_name",
scheduled_time=pendulum.datetime(2023, 4, 1, 20, 0, 0, 0, tz="Europe/Berlin"),
)
run_deployment(
name="flow/deploy_name",
scheduled_time=pendulum.datetime(2023, 4, 2, 20, 0, 0, 0, tz="Europe/Berlin"),
)

最新更新