fixes faust-streaming#197 (faust-streaming#198)

Co-authored-by: David Parker <dparker@novacoast.com>
ekerstens · Oct 21, 2021 · 3959268 · 3959268
1 parent 835f37e
commit 3959268
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/faust/app/base.py b/faust/app/base.py
@@ -1389,7 +1389,7 @@ async def start_client(self) -> None:
         self.client_only = True
         await self.maybe_start()
         self.consumer.stop_flow()
-        await self.topics.wait_for_subscriptions()
+        await self.topics.maybe_wait_for_subscriptions()
         await self.topics.on_client_only_start()
         self.consumer.resume_flow()
         self.flow_control.resume()