88
workflowCache wcache.Cache,
89
logger log.Logger,
91
>
return &workflowResetterImpl{
92
>
shardContext: shardContext,
93
>
namespaceRegistry: shardContext.GetNamespaceRegistry(),
94
>
clusterMetadata: shardContext.GetClusterMetadata(),
95
>
executionMgr: shardContext.GetExecutionManager(),
96
>
workflowCache: workflowCache,
97
>
stateRebuilder: NewStateRebuilder(shardContext, logger),
98
>
transaction: workflow.NewTransaction(shardContext),
99
>
logger: logger,
100
>
}
101
>
}
102
103
// ResetWorkflow resets the given base run and creates a new run that would start after baseNextEventID. It additionally does the following