metricsHandler metrics.Handler,
logger log.Logger,
return &archivalQueueTaskExecutor{
archiver: archiver,
shardContext: shardContext,
workflowCache: workflowCache,
relocatableAttributesFetcher: relocatableAttributesFetcher,
metricsHandler: metricsHandler,
logger: logger,
}
}
// archivalQueueTaskExecutor is an implementation of queues.Executor for the archival queue.