Stash

Parsl · Sep 9, 2024 · 8273cc6 · 8273cc6
1 parent 3ed482e
commit 8273cc6
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/parsl/executors/high_throughput/executor.py b/parsl/executors/high_throughput/executor.py
@@ -661,11 +661,15 @@ def submit(self, func, resource_specification, *args, **kwargs):
         msg = {"task_id": task_id, "buffer": fn_buf}
 
         # Post task to the outgoing queue
-        self.outgoing_q.put(msg)
+        # self.outgoing_q.put(msg)
+        self._submit_task_to_queue(msg)
 
         # Return the future
         return fut
 
+    def _submit_task_to_queue(self, task_dict: dict):
+        self.outgoing_q.put(task_dict)
+
     @property
     def workers_per_node(self) -> Union[int, float]:
         return self._workers_per_node