From 3f4a986c55385e52ecbcc05662e581b711f2dcd2 Mon Sep 17 00:00:00 2001 From: Guillaume Maze Date: Fri, 27 Sep 2024 15:04:31 +0200 Subject: [PATCH] Update filesystems.py --- argopy/stores/filesystems.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/argopy/stores/filesystems.py b/argopy/stores/filesystems.py index a22398aa..9c2e42c0 100644 --- 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://", ""