Update filesystems.py

euroargodev · Sep 27, 2024 · 3f4a986 · 3f4a986
1 parent 594434f
commit 3f4a986
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/argopy/stores/filesystems.py b/argopy/stores/filesystems.py
@@ -1112,7 +1112,8 @@ def open_mfdataset(
         For the :class:`distributed.client.Client` and :class:`concurrent.futures.ProcessPoolExecutor` to work appropriately, the pre-processing :class:`collections.abc.Callable` must be serializable. This can be checked with:
 
         >>> from distributed.protocol import serialize
-        >>> serialize(serialize.ToPickle(preprocess_function))
+        >>> from distributed.protocol.serialize import ToPickle
+        >>> serialize(ToPickle(preprocess_function))
         """
         strUrl = lambda x: x.replace("https://", "").replace(  # noqa: E731
             "http://", ""
@@ -1477,7 +1478,8 @@ def open_mfjson(
         For the :class:`distributed.client.Client` and :class:`concurrent.futures.ProcessPoolExecutor` to work appropriately, the pre-processing :class:`collections.abc.Callable` must be serializable. This can be checked with:
 
         >>> from distributed.protocol import serialize
-        >>> serialize(serialize.ToPickle(preprocess_function))
+        >>> from distributed.protocol.serialize import ToPickle
+        >>> serialize(ToPickle(preprocess_function))
         """
         strUrl = lambda x: x.replace("https://", "").replace(  # noqa: E731
             "http://", ""