This commit is contained in:
2025-08-16 13:49:41 +02:00
parent a0a0bbd110
commit 4593b97bc2

View File

@@ -176,6 +176,7 @@ def raw_weather_batch_latitude(context: dg.AssetExecutionContext) -> None:
io_manager_key="polars_parquet_io_manager", io_manager_key="polars_parquet_io_manager",
partitions_def=daily_partitions_def, partitions_def=daily_partitions_def,
output_required=False, output_required=False,
automation_condition=dg.AutomationCondition.eager(),
) )
def parsed_weather( def parsed_weather(
context: dg.AssetExecutionContext, context: dg.AssetExecutionContext,