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