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

Remove data from header

parent db85b614
......@@ -179,6 +179,7 @@ class AsapoSender:
self.producer.send_stream_finished_flag(stream=self.stream, last_id=last_id, next_stream=next_stream)
def _callback(self, header, err):
header = {key: val for key, val in header.items() if key != 'data'}
with self._lock:
assert self._n_queued > 0
self._n_queued -= 1
......
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