in message_flow/sagas/orchestration_simple_dsl/participant_invocation_impl.py [0:0]
def is_successful_reply(self, message: IMessage) -> bool:
return CommandReplyOutcome.SUCCESS.value == message.get_required_header(
ReplyMessageHeaders.REPLY_OUTCOME
)