guard function_cache

scikit-hep · Mar 19, 2024 · 8b60862 · 8b60862
1 parent 60b0650
commit 8b60862
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/coffea/dataset_tools/apply_processor.py b/src/coffea/dataset_tools/apply_processor.py
@@ -153,7 +153,8 @@ def apply_to_dataset(
                 compression_level=6,
             )
         )()
-        dask.base.function_cache.clear()
+        if hasattr(dask.base, "function_cache"):
+            dask.base.function_cache.clear()
     else:
         out = analysis(events)
         if not isinstance(out, tuple):