61
config *configs.Config,
62
isActive bool,
64
>
return &timerQueueTaskExecutorBase{
65
>
stateMachineEnvironment: stateMachineEnvironment{
66
>
shardContext: shardContext,
67
>
cache: workflowCache,
68
>
logger: logger,
69
>
metricsHandler: metricsHandler,
70
>
},
71
>
currentClusterName: shardContext.GetClusterMetadata().GetCurrentClusterName(),
72
>
registry: shardContext.GetNamespaceRegistry(),
73
>
chasmEngine: chasmEngine,
74
>
deleteManager: deleteManager,
75
>
matchingRawClient: matchingRawClient,
76
>
config: config,
77
>
isActive: isActive,
78
>
}
79
>
}
80
81
func (t *timerQueueTaskExecutorBase) executeDeleteHistoryEventTask(