Commit 4b89063b authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

Add substream name in logs

parent a9ea0b6b
Pipeline #1951 passed with stage
in 46 seconds
import logging import logging
from threading import Event from threading import Event
import threading
from asapo_producer import AsapoProducerError from asapo_producer import AsapoProducerError
from AsapoWorker.errors import ( from AsapoWorker.errors import (
TemporaryError, MissingDataError, ConfigurationError, EndOfStreamError, TemporaryError, MissingDataError, ConfigurationError, EndOfStreamError,
...@@ -239,6 +240,7 @@ class Streamer: ...@@ -239,6 +240,7 @@ class Streamer:
def run(self): def run(self):
try: try:
threading.current_thread().name = f"substream_{self.receiver.substream}"
if self.metadata_receiver: if self.metadata_receiver:
log.info("Waiting for substream metadata") log.info("Waiting for substream metadata")
while not self.stopped.is_set(): while not self.stopped.is_set():
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment