Add check

fractal-analytics-platform · Feb 16, 2024 · 61738c4 · 61738c4
1 parent cfe127c
commit 61738c4
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/runner.py b/src/runner.py
@@ -118,9 +118,10 @@ def print(x):
                     )
             else:
                 # Use pre-made parallelization_list
-                list_function_kwargs = parallelization_list
-                for ind, _ in enumerate(list_function_kwargs):
-                    # FIXME: error or warning in case of overlapping keys
+                list_function_kwargs = deepcopy(parallelization_list)
+                for ind, kwargs in enumerate(list_function_kwargs):
+                    if "root_dir" in kwargs or "buffer" in kwargs:
+                        raise ValueError(f"Invalid {kwargs=}")
                     list_function_kwargs[ind].update(
                         dict(
                             root_dir=tmp_dataset.root_dir,