diff --git a/faststream/_internal/testing/broker.py b/faststream/_internal/testing/broker.py index 3529dccfa7..b079a240bf 100644 --- a/faststream/_internal/testing/broker.py +++ b/faststream/_internal/testing/broker.py @@ -117,11 +117,10 @@ def _patch_broker(self, broker: Broker) -> Generator[None, None, None]: "ping", return_value=True, ): + broker._setup() yield def _fake_start(self, broker: Broker, *args: Any, **kwargs: Any) -> None: - broker._setup() - patch_broker_calls(broker) for p in broker._publishers.values():