move port mailbox into init so it can be seen by typechecker

Parsl · Mar 21, 2023 · 9101ca7 · 9101ca7
1 parent 9576ef0
commit 9101ca7
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/parsl/executors/workqueue/executor.py b/parsl/executors/workqueue/executor.py
@@ -269,6 +269,9 @@ def __init__(self,
         self.worker_executable = worker_executable
         self.function_dir = function_dir
 
+        self._port_mailbox: multiprocessing.Queue[int]
+        self._port_mailbox = multiprocessing.Queue()
+
         if not self.address:
             self.address = socket.gethostname()
 
@@ -315,8 +318,6 @@ def start(self):
 
         logger.debug("Starting WorkQueueExecutor")
 
-        self._port_mailbox = multiprocessing.Queue()
-
         # Create a Process to perform WorkQueue submissions
         submit_process_kwargs = {"task_queue": self.task_queue,
                                  "launch_cmd": self.launch_cmd,