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

Parsl · Apr 4, 2023 · 729efa5 · 729efa5
1 parent 0811837
commit 729efa5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/parsl/executors/workqueue/executor.py b/parsl/executors/workqueue/executor.py
@@ -277,6 +277,9 @@ def __init__(self,
         self.function_dir = function_dir
         self.coprocess = coprocess
 
+        self._port_mailbox: multiprocessing.Queue[int]
+        self._port_mailbox = multiprocessing.Queue()
+
         if not self.address:
             self.address = socket.gethostname()
 
@@ -323,8 +326,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,