Leon Kozlowski
05/06/2022, 4:27 PMKevin Kho
Leon Kozlowski
05/06/2022, 4:29 PMKevin Kho
Leon Kozlowski
05/06/2022, 5:03 PMAnna Geller
Leon Kozlowski
05/06/2022, 6:01 PMLeon Kozlowski
05/06/2022, 6:02 PMflow.schedule = Schedule(
clocks=[
CronClock(
cron="0 1 * * *",
parameter_defaults={"parameter": True}
),
IntervalClock(
interval=timedelta(hours=1)
)
]
)
I would want the CronClock to run with a specific param that would run an additional piece of logic in one of my tasksAnna Geller
from datetime import timedelta
from prefect.schedules import Schedule
from prefect.schedules.clocks import IntervalClock, CronClock
schedule = Schedule(
clocks=[
CronClock(cron="0 1 * * *", parameter_defaults={"parameter": True}),
IntervalClock(interval=timedelta(hours=1)),
]
)
for sched in schedule.next(20):
print(sched)
result is that at 1 AM there are 2 runs, as you wanted:
2022-05-06T19:00:00+00:00
2022-05-06T20:00:00+00:00
2022-05-06T21:00:00+00:00
2022-05-06T22:00:00+00:00
2022-05-06T23:00:00+00:00
2022-05-07T00:00:00+00:00
2022-05-07T01:00:00+00:00
2022-05-07T01:00:00+00:00
2022-05-07T02:00:00+00:00
2022-05-07T03:00:00+00:00
2022-05-07T04:00:00+00:00
2022-05-07T05:00:00+00:00
2022-05-07T06:00:00+00:00
2022-05-07T07:00:00+00:00
2022-05-07T08:00:00+00:00
2022-05-07T09:00:00+00:00
2022-05-07T10:00:00+00:00
2022-05-07T11:00:00+00:00
2022-05-07T12:00:00+00:00
2022-05-07T13:00:00+00:00
Leon Kozlowski
05/06/2022, 6:18 PMLeon Kozlowski
05/06/2022, 6:18 PMAnna Geller
Leon Kozlowski
05/06/2022, 6:19 PM