From a7cbf5498ee2da1442f9a103c5e15329a5a3a882 Mon Sep 17 00:00:00 2001 From: David Parker Date: Thu, 14 Oct 2021 14:48:27 -0700 Subject: [PATCH] fixes #197 --- faust/app/base.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/faust/app/base.py b/faust/app/base.py index 971069a23..4c6850baa 100644 --- 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()