fix

HumanSignal · Oct 30, 2024 · 7af1b08 · 7af1b08
1 parent 3172ad4
commit 7af1b08
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/tasks/stream_inference.py b/server/tasks/stream_inference.py
@@ -158,7 +158,7 @@ async def async_process_streaming_output(
     try:
         while not input_done.is_set():
             data = await consumer.getmany(timeout_ms=timeout_ms, max_records=batch_size)
-            await self.consumer.commit()
+            await consumer.commit()
             for topic_partition, messages in data.items():
                 topic = topic_partition.topic
                 if messages: