in message_flow/sagas/orchestration/saga_manager_factory.py [0:0]
def make(self, saga: Saga[SagaData]) -> SagaManagerImpl:
return SagaManagerImpl(
saga,
self._saga_instance_repository,
self._command_producer,
self._message_consumer,
self._saga_command_producer,
self._saga_data_mapping,
)