https://prefect.io logo
Title
j

JC Garcia

01/13/2021, 10:26 PM
Hey guys! Trying to set up a schedule for one of my flows:
now = datetime.datetime.utcnow()

dev_clock = clocks.IntervalClock(start_date=now, 
                                interval=datetime.timedelta(minutes=10), 
                                parameter_defaults={"some_prop": "someval"})
schedule = Schedule(clocks=[dev_clock])

flow.schedule = schedule
and it works! the problem is that it only schedules 10 runs, and no more. Any pointers?
c

Chris White

01/13/2021, 10:29 PM
Hi @JC Garcia! The Prefect Scheduler only schedules 10 runs in advance, but it will continually check in on the schedule and keep scheduling as needed (but always 10 at a time)
j

JC Garcia

01/13/2021, 10:31 PM
interesting, for some reason, it stopped at the first 10
c

Chris White

01/13/2021, 10:32 PM
are you saying the 10 runs ran and nothing else was ever scheduled?
j

JC Garcia

01/13/2021, 10:32 PM
correct
c

Chris White

01/13/2021, 10:35 PM
can you confirm the scheduler is actually running?
j

JC Garcia

01/13/2021, 10:38 PM
we've got a pod in kubernetes running the
prefecthq/server:latest
image, with the following command:
python src/prefect_server/services/towel/__main__.py
I'll check the logs and see if something is off
👍 1
m

matta

01/14/2021, 1:36 AM
I wonder if maybe there's a mismatch between the Server version and the Flow version (if the Server is set to
latest
)