Add _dask_groupby_kwargs

xarray/core/groupby.py

@@ -269,6 +269,7 @@ class GroupBy:
  "_stacked_dim",
  "_unique_coord",
  "_dims",
+ "_dask_groupby_kwargs",
  )
 
  def __init__(
@@ -406,6 +407,7 @@ def __init__(
  self._inserted_dims = inserted_dims
  self._full_index = full_index
  self._restore_coord_dims = restore_coord_dims
+ self._dask_groupby_kwargs = {}
  # self._by = by
 
  # cached attributes

xarray/core/resample.py

@@ -174,6 +174,8 @@ def __init__(self, *args, dim=None, resample_dim=None, **kwargs):
 
  super().__init__(*args, **kwargs)
 
+ self._dask_groupby_kwargs = dict(method="blockwise")
+
  def map(self, func, shortcut=False, args=(), **kwargs):
  """Apply a function to each array in the group and concatenate them
  together into a new array.
@@ -262,6 +264,7 @@ def __init__(self, *args, dim=None, resample_dim=None, **kwargs):
  self._resample_dim = resample_dim
 
  super().__init__(*args, **kwargs)
+ self._dask_groupby_kwargs = dict(method="blockwise")
 
  def map(self, func, args=(), shortcut=None, **kwargs):
  """Apply a function over each Dataset in the groups generated for