Commit 94c8bac1 authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

enable list of id to be acknowledge

parent 82461e10
Pipeline #6304 failed with stage
in 39 seconds
......@@ -160,10 +160,12 @@ class AsapoSender:
with self._lock:
self._n_queued += 1
if acknowledge is not None and acknowledge not in self._ids_to_acknowledge:
if ack_dependencies is None:
ack_dependencies = [metadata["_id"]]
self._ids_to_acknowledge[acknowledge] = ack_dependencies
if ack_dependencies is None:
ack_dependencies = [metadata["_id"]]
for out_id in acknowledge:
if out_id not in self._ids_to_acknowledge:
self._ids_to_acknowledge[out_id] = ack_dependencies
try:
self.producer.send(
......@@ -214,7 +216,7 @@ class AsapoSender:
if out_id in self._ids_to_acknowledge[in_id]:
if len(self._ids_to_acknowledge[in_id]) == 1:
del self._ids_to_acknowledge[in_id]
id_to_acknowledge = [in_id]
id_to_acknowledge.append(in_id)
else:
self._ids_to_acknowledge[in_id].remove(out_id)
return id_to_acknowledge
......
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