def create()

in message_flow/sagas/orchestration/saga_instance_factory.py [0:0]

• 5 lines of code
• 2 McCabe index (conditional complexity)

    def create(self, saga: Saga[SagaData], data: SagaData) -> SagaInstance:
        saga_manager = self._saga_managers.get(saga)
        if saga_manager is None:
            raise RuntimeError(f"No saga manager for {saga}")

        return saga_manager.create(data)