Commit a22a4749 authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

Apply 1 suggestion(s) to 1 file(s)

parent 4b89063b
Pipeline #1952 passed with stage
in 38 seconds
......@@ -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():
......
Markdown is supported
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