Yury Cheremushkin
03/21/2022, 4:02 PMimport pendulum
from datetime import timedelta
from prefect import Parameter, task, Flow
from prefect.schedules import Schedule
from prefect.schedules.clocks import IntervalClock
schedule = Schedule(clocks=[IntervalClock(start_date=pendulum.datetime(2021, 9, 28, 8, 0, 0, tz="UTC"), interval=timedelta(minutes=10))])
params = {
"message": "message version 1"
}
with Flow("test_changing_parameters_from_ui", schedule=schedule) as flow:
p = Parameter("params", default=params)
task(lambda x: print(x))(p["message"])
I register it in Prefect Cloud. And right after registration Prefect Cloud schedules 10 runs of my Flow.
After that i change message
in this Flow via Cloud UI. For example, set "message": "message version 2"
.
I expect that in the next run updated message will be printed for me. But in fact I need to wait for 10 more runs before i'll be able to see my "message version 2".Kevin Kho
03/21/2022, 4:04 PMYury Cheremushkin
03/21/2022, 4:06 PMKevin Kho
03/21/2022, 4:07 PMflow.register(set_schedule_active=False)
Yury Cheremushkin
03/21/2022, 4:08 PMKevin Kho
04/05/2022, 3:04 PMYury Cheremushkin
04/05/2022, 3:05 PMKevin Kho
04/05/2022, 3:20 PMYury Cheremushkin
04/05/2022, 3:38 PMKevin Kho
04/05/2022, 3:42 PMYury Cheremushkin
04/05/2022, 4:26 PMKevin Kho
04/05/2022, 4:30 PMYury Cheremushkin
04/05/2022, 4:33 PMKevin Kho
04/05/2022, 5:16 PM