in message_flow/sagas/orchestration_simple_dsl/participant_invocation_step.py [0:0]
def make_step_outcome(self, data: Data, compensating: bool) -> IStepOutcome:
pi = self._get_participant_invocation(compensating)
if pi is not None:
commands_to_send = [pi.make_command_to_send(data)]
else:
commands_to_send = []
return StepOutcome.make_remote_outcome(commands_to_send)