def _is_reply_for_this_saga_type()

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

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

    def _is_reply_for_this_saga_type(self, message: IMessage) -> bool:
        if (
            reply_saga_type := message.get_header(SagaReplyHeaders.REPLY_SAGA_TYPE)
        ) is not None:
            return reply_saga_type == self._saga_type

        return False