Commit 9f096471 authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

Always use the last id

parent 908ca2c3
......@@ -62,17 +62,12 @@ class Worker:
"""
pass
def stream_finished(self, last_id=None):
def stream_finished(self):
"""
Function is called at the end of processing and send end-of-stream flag
Parameters
----------
last_id: id of last message in stream. If not given last existing is
considered as last message.
Function is called at the end of processing to send end-of-stream flag
"""
if self.sender:
self.sender.send_end_of_stream(last_id)
self.sender.send_end_of_stream()
else:
raise ConfigurationError(
"Worker wants to send data, but no sender configured!")
......
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