diff --git a/cloud_archives/pv/passiv/passiv_monthly.py b/cloud_archives/pv/passiv/passiv_monthly.py index 89eeb21..49e0309 100644 --- a/cloud_archives/pv/passiv/passiv_monthly.py +++ b/cloud_archives/pv/passiv/passiv_monthly.py @@ -79,6 +79,7 @@ def get_monthly_passiv_data(start_date: datetime, upload_to_hf: bool = True, ove @dg.asset( key=["pv", "passiv", "monthly_30min"], + auto_materialize_policy=dg.AutoMaterializePolicy.eager(), partitions_def=dg.TimeWindowPartitionsDefinition( fmt="%Y-%m", start="2010-01", @@ -99,6 +100,7 @@ def pv_passiv_monthly_30min(context: dg.AssetExecutionContext): @dg.asset( key=["pv", "passiv", "monthly_5min"], + auto_materialize_policy=dg.AutoMaterializePolicy.eager(), partitions_def=dg.TimeWindowPartitionsDefinition( fmt="%Y-%m", start="2018-01", diff --git a/cloud_archives/pv/passiv/passiv_year.py b/cloud_archives/pv/passiv/passiv_year.py index 9b0bf74..dbc8c9d 100644 --- a/cloud_archives/pv/passiv/passiv_year.py +++ b/cloud_archives/pv/passiv/passiv_year.py @@ -67,6 +67,7 @@ def get_yearly_passiv_data(start_date: datetime, upload_to_hf: bool = True, over @dg.asset( key=["pv", "passiv", "yearly_5min"], + auto_materialize_policy=dg.AutoMaterializePolicy.eager(), partitions_def=dg.TimeWindowPartitionsDefinition( fmt="%Y", start="2018", @@ -85,6 +86,7 @@ def pv_passiv_yearly_5min(context: dg.AssetExecutionContext): @dg.asset( key=["pv", "passiv", "yearly_30min"], + auto_materialize_policy=dg.AutoMaterializePolicy.eager(), partitions_def=dg.TimeWindowPartitionsDefinition( fmt="%Y", start="2010",