158
logger log.Logger,
159
bypassVersionSemanticsCheck bool,
161
>
162
>
transactionMgr := &transactionMgrImpl{
163
>
shardContext: shardContext,
164
>
namespaceRegistry: shardContext.GetNamespaceRegistry(),
165
>
workflowCache: workflowCache,
166
>
clusterMetadata: shardContext.GetClusterMetadata(),
167
>
executionManager: shardContext.GetExecutionManager(),
168
>
serializer: shardContext.GetPayloadSerializer(),
169
>
metricsHandler: shardContext.GetMetricsHandler(),
170
>
workflowResetter: NewWorkflowResetter(
171
>
shardContext,
172
>
workflowCache,
173
>
logger,
174
>
),
175
>
eventsReapplier: eventsReapplier,
176
>
logger: logger,
177
>
178
>
createMgr: nil,
179
>
updateMgr: nil,
180
>
}
181
>
taskRefresher := workflow.NewTaskRefresher(shardContext)
182
>
transactionMgr.createMgr = newTransactionMgrForNewWorkflow(shardContext, transactionMgr, bypassVersionSemanticsCheck, taskRefresher)
183
>
transactionMgr.updateMgr = newNDCTransactionMgrForExistingWorkflow(shardContext, transactionMgr, bypassVersionSemanticsCheck, taskRefresher)
184
>
return transactionMgr
185
>
}
186
187
func (r *transactionMgrImpl) CreateWorkflow(