Matthias
06/05/2020, 4:12 PMschedule = IntervalSchedule(
start_date=datetime.utcnow() + timedelta(seconds=1),
interval=timedelta(hours=1),
)
flow.schedule = schedule
flow.register()
and it works, but after 10 intervals, it simply stops. Where am I wrong?Chris White
06/05/2020, 4:17 PMMatthias
06/05/2020, 4:18 PMChris White
06/05/2020, 4:18 PMMatthias
06/05/2020, 4:20 PMChris White
06/05/2020, 4:20 PMMatthias
06/05/2020, 4:40 PMjosh
06/05/2020, 4:57 PMinterval
to something smaller (like every minute) do you see more runs being scheduled once some get ran?Matthias
06/05/2020, 4:58 PMfrom datetime import timedelta, datetime
from prefect import task, Flow
from prefect.schedules import IntervalSchedule
@task
def getone():
return 1
schedule = IntervalSchedule(
start_date=datetime.utcnow() + timedelta(seconds=1),
interval=timedelta(minutes=1),
)
with Flow("testflow", schedule=schedule) as flow:
getone()
flow.register()
Chris White
06/05/2020, 4:59 PMMatthias
06/05/2020, 5:10 PMjosh
06/05/2020, 5:14 PMMatthias
06/05/2020, 9:00 PM