Skip to content

Commit 9b99b51

Browse files
committed
guard function_cache
1 parent f6ff8e5 commit 9b99b51

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

Diff for: src/coffea/dataset_tools/apply_processor.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,8 @@ def apply_to_dataset(
153153
compression_level=6,
154154
)
155155
)()
156-
dask.base.function_cache.clear()
156+
if hasattr(dask.base, "function_cache"):
157+
dask.base.function_cache.clear()
157158
else:
158159
out = analysis(events)
159160
if not isinstance(out, tuple):

0 commit comments

Comments
 (0)