in message_flow/sagas/orchestration/saga_manager_impl.py [0:0]
def _state_definition(self) -> SagaDefinition[Data]:
sm = self._saga.saga_definition
if sm is None:
raise RuntimeError("state machine cannot be null")
return sm