def handle_message()

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

• 8 lines of code
• 2 McCabe index (conditional complexity)

    def handle_message(self, message: IMessage) -> None:
        self._logger.debug("Handle message invoked %s", message)
        if message.has_header(SagaReplyHeaders.REPLY_SAGA_ID):
            self._handle_reply(message)
        else:
            self._logger.warning(
                "Handle message doesn't know what to do with: %s ", message
            )