marcos
01/31/2023, 5:35 PMScheduleDefinition(
job=define_asset_job(
"partitioned_assets_job",
selection=AssetSelection.all(),
partitions_def=StaticPartitionsDefinition(["red", "blue"]),
),
cron_schedule="45 0 * * *",
execution_timezone="America/Chicago",
),
jamie
01/31/2023, 5:42 PMschedule
decorator so that you can specify which partitions should be materialized
yours would look something like this
my_job = define_asset_job(
"partitioned_assets_job",
selection=AssetSelection.all(),
partitions_def=StaticPartitionsDefinition(["red", "blue"]),
)
@schedule(cron_schedule="45 0 * * *", job=my_job)
def red_schedule():
request = my_job.run_request_for_partition(
partition_key="red", run_key=None
)
yield request
this docs section goes over how to set this up https://docs.dagster.io/concepts/partitions-schedules-sensors/schedules#static-partitioned-jobsmarcos
01/31/2023, 5:43 PM