Commit 28d0ca4e authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

Add delay in case if StreamFinish flag is obtained but not messages are acknowledged.

parent c1863fff
......@@ -292,7 +292,7 @@ class Streamer:
log.info("Start stream processing.")
while not self.stopped.is_set():
success = self._process_stream()
if self.likely_done and not success:
if (self.likely_done or self.stream_finished) and not success:
self.stopped.wait(self.delay_on_error)
self._increase_delay_on_error()
else:
......
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