송은철
06/25/2023, 6:33 PM@asset(auto_materialize_policy=AutoMaterializePolicy.lazy())
def parent_asset():
pass
@asset(auto_materialize_policy=AutoMaterializePolicy.lazy(),
freshness_policy=FreshnessPolicy(maximum_lag_minutes=1, cron_schedule="* * * * *"))
def child_asset(parent_asset):
pass
In this configs, child_asset
and parent_asset
are materialized every minutes as expected.
@asset(auto_materialize_policy=AutoMaterializePolicy.lazy())
def parent_asset():
pass
@asset(auto_materialize_policy=AutoMaterializePolicy.lazy(),
partitions_def=HourlyPartitionsDefinition(start_date="2023-06-25-16:00"),
freshness_policy=FreshnessPolicy(maximum_lag_minutes=60, cron_schedule="* * * * *"))
def partitioned_child_asset(parent_asset):
pass
But If I partition the child asset, none of the assets are materialized. Digit says no materialization conditions met. Is it bug? Or am I missing something?
dagster version is 1.3.11sean
06/27/2023, 11:21 PMsean
06/30/2023, 2:27 PM