Jacob Marcil
02/15/2023, 4:33 PMbuild_schedule_from_partition_job
but they doesn’t seem to work for hourly partition.
https://docs.dagster.io/concepts/partitions-schedules-sensors/schedulesowen
02/15/2023, 6:12 PMend_offset
parameter), so that the partition key 2023-01-05-05:00
actually corresponds to data from 2023-01-04-05:00
. In some scenarios, this makes more sense, but in others this would be confusing.
Another option would be to create a custom schedule that runs hourly and manually feeds in the desired partition:
@schedule(cron_schedule="0 * * * *", job=my_job)
def my_schedule():
# pseudo code
partition_key = (current_time - "1 day").to_string()
return my_job.run_request_for_partition(partition_key=partition_key)
Jacob Marcil
02/15/2023, 6:24 PMowen
02/15/2023, 6:24 PMJacob Marcil
02/15/2023, 6:25 PM