Skip to content

Commit 57c9279

Browse files
authored
Correct type annotation on monitoring _migrate_logs_to_internal (#3918)
This isn't type-checked by mypy on invocation because the invocation is via a Thread() object rather than a regular function call. # Changed Behaviour none ## Type of change - Code maintenance/cleanup
1 parent 97d23d1 commit 57c9279

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

parsl/monitoring/db_manager.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -552,7 +552,7 @@ def start(self,
552552
raise RuntimeError("An exception happened sometime during database processing and should have been logged in database_manager.log")
553553

554554
@wrap_with_logs(target="database_manager")
555-
def _migrate_logs_to_internal(self, logs_queue: queue.Queue, kill_event: threading.Event) -> None:
555+
def _migrate_logs_to_internal(self, logs_queue: mpq.Queue, kill_event: threading.Event) -> None:
556556
logger.info("Starting _migrate_logs_to_internal")
557557

558558
while not kill_event.is_set() or logs_queue.qsize() != 0:

0 commit comments

Comments
 (0)