File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change 33"""Scheduler for commands and events."""
44
55__author__ = "Marcin Usielski"
6- __copyright__ = "Copyright (C) 2019-2023 , Nokia"
6+ __copyright__ = "Copyright (C) 2019-2025 , Nokia"
7788
99import logging
1010import threading
1111import time
1212from threading import Thread
1313
14+ from moler .connection_observer import ConnectionObserver
1415from moler .exceptions import CommandTimeout
1516
1617
1718class CommandScheduler :
1819 """Scheduler for commands and events."""
1920
2021 @staticmethod
21- def enqueue_starting_on_connection (connection_observer ):
22+ def enqueue_starting_on_connection (connection_observer : ConnectionObserver ):
2223 """
2324 Wait for free slot and runs command when no other command is in run mode.
2425
@@ -43,6 +44,7 @@ def enqueue_starting_on_connection(connection_observer):
4344 )
4445 t1 .daemon = True
4546 t1 .start ()
47+ connection_observer .logger .warning (f"Requested to execute command ({ connection_observer } ) but the other command is running. Waiting for a free slot." )
4648
4749 @staticmethod
4850 def dequeue_running_on_connection (connection_observer ):
You can’t perform that action at this time.
0 commit comments