Hebo Yang
08/31/2022, 8:45 PMHebo Yang
08/31/2022, 8:47 PMdefine_asset_job
return None for get_partition_set_def()
partition = job.get_partition_set_def().get_partition(active_date_str)
tags = job.get_partition_set_def().tags_for_partition(partition)
Hebo Yang
08/31/2022, 8:50 PMdef get_daily_partition_config():
@daily_partitioned_config(
start_date=PARTITION_START_DATE, timezone=str(TZ), end_offset=1
)
def daily_partition_config(start: datetime, _end: datetime):
return self.create_run_config_for_date(start)
return daily_partition_config
job = define_asset_job(
name="job_name",
config=get_daily_partition_config(),
selection=AssetSelection.assets(asset),
)
sandy
08/31/2022, 8:51 PMjob.run_request_for_partition(partition_key=active_date_str, run_key=None)
sandy
08/31/2022, 8:53 PMHebo Yang
08/31/2022, 8:53 PM