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

Merge branch 'feat/streamfinish_delay' into 'master'

Add delay in case if StreamFinish flag is obtained

See merge request fs-sc/asapoworker!34
parents c1863fff 28d0ca4e
......@@ -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