def subscribe_to_reply_channel()

in message_flow/sagas/orchestration/saga_manager_impl.py [0:0]

• 6 lines of code
• 1 McCabe index (conditional complexity)

    def subscribe_to_reply_channel(self) -> None:
        self._message_consumer.subscribe(
            {self._make_saga_reply_channel()},
            self.handle_message,
            queue=self._make_saga_reply_queue(),
        )