jstet
06/13/2023, 11:16 PMjstet
06/14/2023, 1:05 PMdef generate_hourly_cron_schedule():
# schedule should start after dagster is started, so generate a cronjob taking current minute into account
now = datetime.datetime.now()
minute = now.minute+1
cron_schedule = f"{minute} * * * *"
return cron_schedule
owen
06/14/2023, 11:52 PMdagster dev
?
it seems like the basic behavior you're looking for is "run once an hour, starting from when the dagster dev process was initiated", is that accurate? A more stable version of that than your above code might just be to do something like
STARTUP_MINUTE=$(date +"%M") dagster dev -f ...
owen
06/14/2023, 11:53 PMowen
06/14/2023, 11:53 PM