phương đinh
05/17/2022, 4:02 AMjamie
05/17/2022, 3:41 PM@daily_partitioned_config(start_date=datetime(2020, 1, 1))
def my_partitioned_config(start: datetime, _end: datetime):
return {
"ops": {
"process_data_for_date": {"config": {"date": start.strftime("%Y-%m-%d")}}
}
}
And ran a backfill of the dates 5/14/22 and 5/15/22 you would get the run configs that would be generated from my_partitioned_config(start_date=datetime(2022, 5, 14), _end: datetime(2022, 5, 15))
and my_partitioned_config(start_date=datetime(2022, 5, 15), _end=datetime(2022, 5, 16))