David Mulhall
05/27/2022, 8:03 AMsean
05/27/2022, 1:25 PMDavid Mulhall
05/30/2022, 5:43 AMDavid Mulhall
05/30/2022, 5:44 AM@schedule(
job=job1,
execution_timezone="Europe/Berlin",
cron_schedule="*/5 * * * *",
default_status=DefaultScheduleStatus.RUNNING
)
def job1_schedule():
for config in [config1, config2, config3, ....]
yield RunRequest(
run_key="job1",
run_config= config
)
Is there a way to loop over my configs and create a schedule for each one?sean
05/30/2022, 10:45 PMschedules = []
for i, config in enumerate([config1, config2, config3]):
@schedule(job=job1, name=f"job1_schedule_{i}", ...)
def schedule_func():
yield RunRequest(...)
schedules.append(schedule_func)
sean
06/01/2022, 6:53 PMDavid Mulhall
06/03/2022, 6:03 AM