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()