Skip to content

Commit

Permalink
this was annotated as taking a queue.Queue not a multiprocessing Queu…
Browse files Browse the repository at this point in the history
…e, which is not true
  • Loading branch information
benclifford committed Oct 31, 2024
1 parent ff97c6e commit 22e62ae
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion parsl/monitoring/monitoring.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 22e62ae

Please sign in to comment.