Raise error when resource_dict is used in function parameters

pympipool/shared/executorbase.py

@@ -70,6 +70,8 @@ def submit(self, fn: callable, *args, resource_dict: dict = {}, **kwargs):
             raise ValueError(
                 "When block_allocation is enabled, the resource requirements have to be defined on the executor level."
             )
+        if "resource_dict" in inspect.signature(fn).parameters.keys():
+            raise ValueError("The parameter resource_dict is used internally in pympipool, so it cannot be used as parameter in the submitted functions.")
         f = Future()
         self._future_queue.put({"fn": fn, "args": args, "kwargs": kwargs, "future": f})
         return f
@@ -171,6 +173,8 @@ def submit(self, fn: callable, *args, resource_dict: dict = {}, **kwargs):
         Returns:
             A Future representing the given call.
         """
+        if "resource_dict" in inspect.signature(fn).parameters.keys():
+            raise ValueError("The parameter resource_dict is used internally in pympipool, so it cannot be used as parameter in the submitted functions.")
         f = Future()
         self._future_queue.put(
             {

tests/test_executor_backend_mpi_noblock.py

@@ -16,6 +16,10 @@ def mpi_funct(i):
     return i, size, rank
 
 
+def resource_dict(resource_dict):
+    return resource_dict
+
+
 class TestExecutorBackend(unittest.TestCase):
     def test_meta_executor_serial(self):
         with Executor(
@@ -58,3 +62,13 @@ def test_errors(self):
                 hostname_localhost=True,
                 backend="mpi",
             )
+        with self.assertRaises(ValueError):
+            with Executor(
+                max_cores=1, hostname_localhost=True, backend="mpi", block_allocation=False
+            ) as exe:
+                exe.submit(resource_dict, resource_dict={})
+        with self.assertRaises(ValueError):
+            with Executor(
+                max_cores=1, hostname_localhost=True, backend="mpi", block_allocation=True
+            ) as exe:
+                exe.submit(resource_dict, resource_dict={})