diff --git a/parsl/monitoring/monitoring.py b/parsl/monitoring/monitoring.py index 1762fb10f2..134e1ba50f 100644 --- a/parsl/monitoring/monitoring.py +++ b/parsl/monitoring/monitoring.py @@ -252,7 +252,7 @@ def close(self) -> None: @wrap_with_logs -def filesystem_receiver(q: "queue.Queue[TaggedMonitoringMessage]", run_dir: str) -> None: +def filesystem_receiver(q: Queue[TaggedMonitoringMessage], run_dir: str) -> None: logger = set_file_logger("{}/monitoring_filesystem_radio.log".format(run_dir), name="monitoring_filesystem_radio", level=logging.INFO)