Merge pull request #30 from openearthplatforminitiative/fix/use-dask-…

…in-transformed fix: use dask resource in transformed asset
openearthplatforminitiative · May 6, 2024 · d0c87da · d0c87da
2 parents 37afba8 + a69db47
commit d0c87da
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/data_pipelines/assets/flood/discharge.py b/data_pipelines/assets/flood/discharge.py
@@ -85,6 +85,7 @@ def raw_discharge(context: AssetExecutionContext, cds_client: CDSClient) -> None
 )
 def transformed_discharge(
     context: AssetExecutionContext,
+    dask_resource: DaskResource,
     raw_discharge: xr.Dataset,
     uparea_glofas_v4_0: xr.Dataset,
 ) -> pd.DataFrame: