Lucian Rosu
12/17/2021, 12:41 PMschedule = Schedule(
clocks=[clocks.IntervalClock(timedelta(days=1))],
# filters=[filters.at_time(time(10))],
or_filters=[filters.between_times(pendulum.time(9), pendulum.time(9))]
)
Anna Geller
from datetime import timedelta
import pendulum
from prefect.schedules import Schedule
from prefect.schedules.clocks import IntervalClock
from prefect.schedules.filters import at_time, between_times
clock = IntervalClock(
start_date=pendulum.datetime(2021, 12, 17, 9, 0, tz="America/New_York"),
interval=timedelta(hours=1),
)
schedule = Schedule(clocks=[clock],
or_filters=[between_times(pendulum.time(9), pendulum.time(17))]
)
for sched in schedule.next(20):
print(sched)
Output:
2021-12-17T09:00:00-05:00
2021-12-17T10:00:00-05:00
2021-12-17T11:00:00-05:00
2021-12-17T12:00:00-05:00
2021-12-17T13:00:00-05:00
2021-12-17T14:00:00-05:00
2021-12-17T15:00:00-05:00
2021-12-17T16:00:00-05:00
2021-12-17T17:00:00-05:00
2021-12-18T09:00:00-05:00
2021-12-18T10:00:00-05:00
2021-12-18T11:00:00-05:00
2021-12-18T12:00:00-05:00
2021-12-18T13:00:00-05:00
2021-12-18T14:00:00-05:00
2021-12-18T15:00:00-05:00
2021-12-18T16:00:00-05:00
2021-12-18T17:00:00-05:00
2021-12-19T09:00:00-05:00
2021-12-19T10:00:00-05:00
Lucian Rosu
12/17/2021, 1:25 PMclock = clocks.IntervalClock(
    start_date=pendulum.yesterday(tz='Europe/Bucharest'),
    interval=timedelta(hours=1),
  )
 Â
  schedule = Schedule(
    clocks=[clock],
    filters=[filters.at_time(pendulum.time(10))],
  )