diff --git a/parsl/executors/high_throughput/executor.py b/parsl/executors/high_throughput/executor.py
index e589975fb5..4e6c390d09 100644
--- 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