in saga-core/src/main/java/org/apache/servicecomb/saga/core/dag/GraphBasedSagaFactory.java [57:70]
public Saga createSaga(String requestJson, String sagaId, EventStore sagaLog, SagaDefinition definition) {
SagaContext sagaContext = new SagaContextImpl(childrenExtractor);
return new GraphBasedSaga(
sagaLog,
executorService,
sagaTaskFactory.sagaTasks(sagaId,
requestJson,
definition.policy(),
new ContextAwareEventStore(sagaLog, sagaContext)
),
sagaContext,
graphBuilder.build(definition.requests()));
}