forgot to return heap

kaufland-ecommerce · Aug 27, 2020 · 2023cd9 · 2023cd9
1 parent 49c0390
commit 2023cd9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/esque/clients/consumer.py b/esque/clients/consumer.py
@@ -393,6 +393,7 @@ def _consume_message_to_heap(consumer: AbstractConsumer, heap: list):
     message = consumer.consume_single_acceptable_message()
     decoded_message = decode_message(message)
     heappush(heap, (decoded_message.timestamp, message))
+    return heap
 
 
 def consume_to_files(