in message_flow/sagas/orchestration_simple_dsl/abstract_simple_saga_definition.py [0:0]
def _saga_actions_for_next_step(
self,
saga_type: str,
saga_id: str,
saga_data: Data,
message: IMessage,
state: SagaExecutionState,
current_step: Step,
compensating: bool,