fix errors in seek when flow is not active (faust-streaming#264)

* fix errors in seek when flow is not active * fix errors in seek when flow is not active * Revert "fix errors in seek when flow is not active" This reverts commit c3fadfb.
hamzah-jamal · Feb 4, 2022 · a313821 · a313821
1 parent b5e7ce8
commit a313821
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/faust/transport/consumer.py b/faust/transport/consumer.py
@@ -753,7 +753,10 @@ async def getmany(self, timeout: float) -> AsyncIterator[Tuple[TP, Message]]:
             self.log.dev(
                 "getmany called while flow not active. Seek back to committed offsets."
             )
-            await self.perform_seek()
+            try:
+                await self.perform_seek()
+            except Exception as ex:
+                self.log.warning(f"exception performing seek when flow not active {ex}")
 
     async def _wait_next_records(
         self, timeout: float