From 4b89063ba6a54407511737e04fe3a6fd1d35d196 Mon Sep 17 00:00:00 2001 From: karnem Date: Thu, 7 Jan 2021 12:20:34 +0100 Subject: [PATCH 1/2] Add substream name in logs --- src/AsapoWorker/streamer.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/AsapoWorker/streamer.py b/src/AsapoWorker/streamer.py index 7b97afb..d63aaca 100644 --- a/src/AsapoWorker/streamer.py +++ b/src/AsapoWorker/streamer.py @@ -1,5 +1,6 @@ import logging from threading import Event +import threading from asapo_producer import AsapoProducerError from AsapoWorker.errors import ( TemporaryError, MissingDataError, ConfigurationError, EndOfStreamError, @@ -239,6 +240,7 @@ class Streamer: def run(self): try: + threading.current_thread().name = f"substream_{self.receiver.substream}" if self.metadata_receiver: log.info("Waiting for substream metadata") while not self.stopped.is_set(): -- GitLab From a22a4749e68369aab09f2f88efb5466a81f66210 Mon Sep 17 00:00:00 2001 From: Mikhail Karnevskiy Date: Thu, 7 Jan 2021 11:51:50 +0000 Subject: [PATCH 2/2] Apply 1 suggestion(s) to 1 file(s) --- src/AsapoWorker/streamer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/AsapoWorker/streamer.py b/src/AsapoWorker/streamer.py index d63aaca..a920146 100644 --- a/src/AsapoWorker/streamer.py +++ b/src/AsapoWorker/streamer.py @@ -240,7 +240,8 @@ class Streamer: def run(self): try: - threading.current_thread().name = f"substream_{self.receiver.substream}" + threading.current_thread().name = "substream_{}".format( + self.receiver.substream) if self.metadata_receiver: log.info("Waiting for substream metadata") while not self.stopped.is_set(): -- GitLab