fix(playout): add thread names (#2056)

playout/libretime_playout/message_handler.py

@@ -27,6 +27,8 @@ class RabbitConsumer(ConsumerMixin):
 
 
 class PypoMessageHandler(Thread):
+    name = "message_handler"
+
     def __init__(self, pq, rq, config: RabbitMQConfig):
         Thread.__init__(self)
         self.pypo_queue = pq

playout/libretime_playout/player/fetch.py

@@ -30,6 +30,8 @@ signal.signal(signal.SIGINT, keyboardInterruptHandler)
 
 
 class PypoFetch(Thread):
+    name = "fetch"
+
     def __init__(
         self,
         pypoFetch_q,

playout/libretime_playout/player/file.py

@@ -11,6 +11,8 @@ from requests.exceptions import ConnectionError, HTTPError, Timeout
 
 
 class PypoFile(Thread):
+    name = "file"
+
     def __init__(self, schedule_queue, api_client: ApiClient):
         Thread.__init__(self)
         self.media_queue = schedule_queue

playout/libretime_playout/player/push.py

@@ -21,6 +21,8 @@ def is_file(media_item):
 
 
 class PypoPush(Thread):
+    name = "push"
+
     def __init__(self, q, telnet_lock, pypo_liquidsoap, config: Config):
         Thread.__init__(self)
         self.queue = q

playout/libretime_playout/player/queue.py

@@ -19,6 +19,8 @@ signal.signal(signal.SIGINT, keyboardInterruptHandler)
 
 
 class PypoLiqQueue(Thread):
+    name = "liquidsoap_queue"
+
     def __init__(self, q, pypo_liquidsoap):
         Thread.__init__(self)
         self.queue = q

playout/libretime_playout/recorder.py

@@ -36,6 +36,8 @@ def getDateTimeObj(time):
 
 
 class ShowRecorder(Thread):
+    name = "show_recorder"
+
     def __init__(
         self,
         show_instance,

playout/libretime_playout/timeout.py

@@ -5,6 +5,8 @@ from .player import fetch
 
 def __timeout(func, timeout_duration, default, args, kwargs):
     class InterruptableThread(threading.Thread):
+        name = "liquidsoap_timeout"
+
         def __init__(self):
             threading.Thread.__init__(self)
             self.result = default