DaskCube

semantique/processor/arrays.py

@@ -768,7 +768,7 @@ def delineate(self, track_types = True, **kwargs):
 
     """
     # Get and check array.
-    obj = xr.apply_ufunc(utils.null_as_zero, self._obj)
+    obj = utils.apply_ufunc(utils.null_as_zero, self._obj)
     if track_types:
       vtype = obj.sq.value_type
       if vtype is not None and vtype != "binary":
@@ -816,7 +816,7 @@ def delineate(self, track_types = True, **kwargs):
         f"and/or '{SPACE}', not: {list(dims)}"
       )
     # Delineate.
-    out = xr.apply_ufunc(lambda x, y: ndimage.label(x, y)[0], obj, nb)
+    out = utils.apply_ufunc(lambda x, y: ndimage.label(x, y)[0], obj, nb)
     # Post-process.
     out = out.where(pd.notnull(self._obj)) # Preserve nan.
     if track_types:

semantique/processor/core.py

@@ -1086,14 +1086,15 @@ def call_verb(self, name, params):
     verb = getattr(obj.sq, name)
     out = verb(**params)
     # Warn when output array is empty.
-    try:
-      is_empty = out.sq.is_empty
-    except AttributeError:
-      is_empty = out.is_empty
-    if is_empty:
-      warnings.warn(
-        f"Verb '{name}' returned an empty array"
-      )
+    # Removed for Dask. TODO: Put behind config flag.
+    # try:
+    #   is_empty = out.sq.is_empty
+    # except AttributeError:
+    #   is_empty = out.is_empty
+    # if is_empty:
+    #   warnings.warn(
+    #     f"Verb '{name}' returned an empty array"
+    #   )
     logger.debug(f"Applied verb {name}:\n{out}")
     return out