Jared
06/01/2020, 6:52 PMIntervalSchedule
tasks to run 10 times (this is using Core/not on cloud). Am I missing something obvious?
When I initially register the flow, 10 runs get queued and executed, but no more. In the terminal running the server, the scheduler wakes, schedules 0 runs, and sleeps even if all 10 original runs have passed. On-demand runs in the UI still work at this point. I'll comment with what I'm doing to reproduce.prefect server start
and prefect agent start
both run fine. Then from the interpreter in the same env:
from datetime import timedelta, datetime
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()
Kyle Moon-Wright
06/01/2020, 7:15 PMJared
06/01/2020, 8:00 PMscheduler_1 | [2020-05-31 12:10:53,195] INFO - prefect-server.Scheduler | Scheduled 0 flow runs.
graphql_1 | INFO: 192.168.0.6:55604 - "POST /graphql/ HTTP/1.1" 200 OK
scheduler_1 | [2020-05-31 12:10:53,296] DEBUG - prefect-server.Scheduler | Sleeping for 300.0 seconds...
Kyle Moon-Wright
06/01/2020, 8:37 PMtestflow
on my own Prefect Server (using 0.11.4) with a Local Agent and after 5 flow runs, the UI repopulates the queue to 10 Upcoming Runs on my Dashboard. Would you mind opening issue on Github for greater visibility for the team?scheduler_1 | [2020-06-01 20:43:28,833] DEBUG - prefect-server.api.schedules | Flow run <flow_run_id> of flow <flow_id> scheduled for 2020-06-01T20:53:20.963042+00:00
# this occurs x5, x1 for each run
scheduler_1 | [2020-06-01 20:43:28,856] INFO - prefect-server.Scheduler | Scheduled 5 flow runs.
scheduler_1 | [2020-06-01 20:43:28,972] DEBUG - prefect-server.api.schedules | Schedule <schedule_id> was not ready for new scheduling.
scheduler_1 | [2020-06-01 20:43:28,972] INFO - prefect-server.Scheduler | Scheduled 0 flow runs.
scheduler_1 | [2020-06-01 20:43:29,073] DEBUG - prefect-server.Scheduler | Sleeping for 300.0 seconds...