Frederik Löw
06/14/2023, 8:10 PM@schedule(job=partitioned_data_job, cron_schedule="0 0 * * *",
default_status=DefaultScheduleStatus.RUNNING)
def sophia_1_schedule(context: ScheduleEvaluationContext):
partitions = sophia_assets_partition.get_partition_keys()
# scheduled_date = context.scheduled_execution_time.strftime("%Y-%m-%d")
for part in partitions:
yield RunRequest(run_key= part, partition_key= part)
From what I think, this schedule should be set to running by default. But it doesn't as you can see in the picture. I have searched the doc and also a github issue https://github.com/dagster-io/dagster/issues/4103. What am I missing here? I am using dagster 1..3.4owen
06/14/2023, 11:30 PMFrederik Löw
06/15/2023, 12:32 PMowen
06/15/2023, 4:39 PMFrederik Löw
06/15/2023, 7:46 PM