From 34ea87a0575c07517a813648764020baa82223d3 Mon Sep 17 00:00:00 2001 From: Ben Clifford Date: Mon, 1 Sep 2025 20:09:50 +0000 Subject: [PATCH] Replace SizedQueue use in monitoring with regular Queue Since PR #3937, no .qsize() has been used in monitoring. This leaves MacSafeQueue, the Mac implementation of SizedQueue, unused. It will be removed in a subsequent PR. --- parsl/monitoring/monitoring.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/parsl/monitoring/monitoring.py b/parsl/monitoring/monitoring.py index b4a005e21c..8020a82576 100644 --- a/parsl/monitoring/monitoring.py +++ b/parsl/monitoring/monitoring.py @@ -11,9 +11,9 @@ from parsl.monitoring.types import TaggedMonitoringMessage from parsl.multiprocessing import ( - SizedQueue, SpawnEvent, SpawnProcess, + SpawnQueue, join_terminate_close_proc, ) from parsl.utils import RepresentationMixin @@ -126,7 +126,7 @@ def start(self, dfk_run_dir: str, config_run_dir: Union[str, os.PathLike]) -> No self.monitoring_hub_active = True self.resource_msgs: Queue[TaggedMonitoringMessage] - self.resource_msgs = SizedQueue() + self.resource_msgs = SpawnQueue() self.dbm_exit_event: ms.Event self.dbm_exit_event = SpawnEvent()