Krishna Somasundaram Rm ee19b147
07/04/2022, 6:29 AMfrom dagster import job,op,ScheduleDefinition,repository,DefaultScheduleStatus, schedule
@op
def on_time(context):
<http://context.log.info|context.log.info>("I have been scheduled")
@job
def time_job():
on_time()
### Schedule to run every 5 minutes
regular_schedule = ScheduleDefinition(
job=time_job, cron_schedule="0/5 * * * *", default_status=DefaultScheduleStatus.RUNNING
)
### Every Tuesday and Thursday
zumba_class_schedule = ScheduleDefinition(
job=time_job, cron_schedule="00 20 */1 * 2,4", default_status=DefaultScheduleStatus.RUNNING
)
@repository
def timer_repo():
return [time_job,regular_schedule,zumba_class_schedule]
When I try to run this code, it throws the error: Duplicate definition found for time_job_schedule. How else should I define multiple schedules for a job?Krishna Somasundaram Rm ee19b147
07/04/2022, 6:42 AM