From 9101ca76033db0293e41e1a68b8b1955ff65b17c Mon Sep 17 00:00:00 2001 From: Ben Clifford Date: Tue, 21 Mar 2023 14:07:18 +0000 Subject: [PATCH] move port mailbox into init so it can be seen by typechecker --- parsl/executors/workqueue/executor.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/parsl/executors/workqueue/executor.py b/parsl/executors/workqueue/executor.py index ae59c71996..b7e6dc2939 100644 --- 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,