add automatrilize

openclimatefix · Jul 17, 2024 · 6793f56 · 6793f56
1 parent 4916735
commit 6793f56
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git 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
@@ -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",