ag input processing

Kit Schwarz · Kit Schwarz · commit 9c2679af8e8b · 2022-08-05T11:53:35.000-07:00
diff --git a/dscim/preprocessing/input_damages.py b/dscim/preprocessing/input_damages.py
@@ -346,8 +346,8 @@ def process_batch(g):
     )
     batches = xr.where(np.isinf(batches), np.nan, batches)
 
-    batches.rename({"wc_reallocation": varname}).to_zarr(
-        save_path, mode="w", consolidated=True
+    batches.rename({"wc_reallocation": varname})[varname].to_zarr(
+        save_path, mode="a", consolidated=True
     )
 
 

Original file line number	Diff line number	Diff line change
`@@ -346,8 +346,8 @@ def process_batch(g):`
`346`	`346`	`)`
`347`	`347`	`batches = xr.where(np.isinf(batches), np.nan, batches)`
`348`	`348`
`349`		`- batches.rename({"wc_reallocation": varname}).to_zarr(`
`350`		`- save_path, mode="w", consolidated=True`
	`349`	`+ batches.rename({"wc_reallocation": varname})[varname].to_zarr(`
	`350`	`+ save_path, mode="a", consolidated=True`
`351`	`351`	`)`
`352`	`352`
`353`	`353`