def with_success()

in message_flow/sagas/participant/plugin_reply_builder.py [0:0]

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

    def with_success(self, reply: Any = Success()) -> Tuple[str, IMessage]:
        return self._destination, (
            MessageBuilder.with_payload(JsonMapper().serialize(reply))
            .with_header(
                ReplyMessageHeaders.REPLY_OUTCOME, CommandReplyOutcome.SUCCESS.value
            )
            .with_header(ReplyMessageHeaders.REPLY_TYPE, reply.__class__.__name__)
            .with_header(IMessage.ID, uuid4().hex)
            .with_extra_headers("", self._routing_info)
            .build()
        )