Workaround dask#6631 (#246)

ravwojdyla · web-flow · commit ffd85e0e1f27 · 2020-09-14T09:56:43.000+01:00
Wrap around list to delegate eq to dask not std python
diff --git a/sgkit/io/vcfzarr_reader.py b/sgkit/io/vcfzarr_reader.py
@@ -61,9 +61,11 @@ def read_vcfzarr(path: PathType) -> xr.Dataset:
     )
 
     # Add a mask for variant ID
+    # Note: we wrap the "." inside a list to workaround https://github.com/dask/dask/issues/6631,
+    #       and therefor force dask array's eq
     ds["variant_id_mask"] = (
         [DIM_VARIANT],
-        variants_id == ".",
+        variants_id == ["."],
     )
 
     return ds

Original file line number	Diff line number	Diff line change
`@@ -61,9 +61,11 @@ def read_vcfzarr(path: PathType) -> xr.Dataset:`
`61`	`61`	`)`
`62`	`62`
`63`	`63`	`# Add a mask for variant ID`
	`64`	`+ # Note: we wrap the "." inside a list to workaround https://github.com/dask/dask/issues/6631,`
	`65`	`+ # and therefor force dask array's eq`
`64`	`66`	`ds["variant_id_mask"] = (`
`65`	`67`	`[DIM_VARIANT],`
`66`		`- variants_id == ".",`
	`68`	`+ variants_id == ["."],`
`67`	`69`	`)`
`68`	`70`
`69`	`71`	`return ds`