From 4ba97e7cf6541d8bd219c9fcc73b6333cad82937 Mon Sep 17 00:00:00 2001 From: Peter Dudfield <34686298+peterdudfield@users.noreply.github.com> Date: Wed, 17 Jul 2024 14:05:50 +0100 Subject: [PATCH] add automatrilize (#118) --- cloud_archives/pv/passiv/passiv_monthly.py | 2 ++ cloud_archives/pv/passiv/passiv_year.py | 2 ++ 2 files changed, 4 insertions(+) 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",