86
enableDataLossMetrics EnableDataLossMetrics,
87
enableBestEffortDeleteTasksOnWorkflowUpdate EnableBestEffortDeleteTasksOnWorkflowUpdate,
89
>
factory := &factoryImpl{
90
>
dataStoreFactory: dataStoreFactory,
91
>
config: cfg,
92
>
serializer: serializer,
93
>
eventBlobCache: eventBlobCache,
94
>
metricsHandler: metricsHandler,
95
>
logger: logger,
96
>
clusterName: clusterName,
97
>
systemRateLimiter: systemRateLimiter,
98
>
namespaceRateLimiter: namespaceRateLimiter,
99
>
shardRateLimiter: shardRateLimiter,
100
>
healthSignals: healthSignals,
101
>
enableDataLossMetrics: dynamicconfig.BoolPropertyFn(enableDataLossMetrics),
102
>
enableBestEffortDeleteTasksOnWorkflowUpdate: dynamicconfig.BoolPropertyFn(enableBestEffortDeleteTasksOnWorkflowUpdate),
103
>
}
104
>
factory.initDependencies()
105
>
return factory
106
>
}
107
108
// NewTaskManager returns a new task manager