shailesh
04/27/2023, 3:16 PMfrom dagster import (
AssetIn,
DailyPartitionsDefinition,
MonthlyPartitionsDefinition,
TimeWindowPartitionMapping,
asset,
)
partitions_def_daily = DailyPartitionsDefinition(start_date="2023-01-01")
partitions_def_monthly = MonthlyPartitionsDefinition(start_date="2023-01-01")
@asset(partitions_def=partitions_def_daily)
def daily_asset():
...
@asset(
partitions_def=partitions_def_monthly
)
def monthly_asset(daily_asset):
...
But when I am executing job getting error :
Selected assets must have the same partitions definitions, but the selected assets have different partitions definitions:
I had refered this link: https://docs.dagster.io/concepts/partitions-schedules-sensors/partitions#partition-dependencies
Please help me out, how can I achieve both daily and monthly partition in one job
🙏chris
04/27/2023, 6:15 PMshailesh
05/08/2023, 12:21 PMfrom dagster import (
AssetIn,
DailyPartitionsDefinition,
MonthlyPartitionsDefinition,
TimeWindowPartitionMapping,
asset,
)
partitions_def_daily = DailyPartitionsDefinition(start_date="2023-01-01")
partitions_def_monthly = MonthlyPartitionsDefinition(start_date="2023-01-01")
@asset(partitions_def=partitions_def_daily)
def daily_asset():
...
@asset(
partitions_def=partitions_def_monthly,
ins={
"daily_asset": AssetIn(
partition_mapping=TimeWindowPartitionMapping(
start_offset=-1, end_offset=-1
),
)
}
)
def monthly_asset(daily_asset):
Still getting same error :
Selected assets must have the same partitions definitions, but the selected assets have different partitions definitions:
chris
05/26/2023, 4:12 PM