1 parent 3eeabbc commit a497e97Copy full SHA for a497e97
1 file changed
src/workflows/services/common_service.py
@@ -301,6 +301,9 @@ def __command_queue_listener(self):
301
This function is run by a separate daemon thread, which is started by
302
the __start_command_queue_listener function.
303
"""
304
+ assert self.__pipe_commands is not None, (
305
+ "Listener started without command queue connection"
306
+ )
307
self.log.debug("Queue listener thread started")
308
counter = itertools.count() # insertion sequence to keep messages in order
309
while not self.__shutdown:
@@ -336,7 +339,7 @@ def __start_command_queue_listener(self):
336
339
thread_function = self.__command_queue_listener
337
340
338
341
class QueueListenerThread(threading.Thread):
- def run(qltself):
342
+ def run(self):
343
thread_function()
344
345
assert not hasattr(self, "__queue_listener_thread")
0 commit comments