logger log.Logger,
testHooks testhooks.TestHooks,
return &taskExecutorImpl{
currentCluster: currentCluster,
metadataManager: metadataManagerV2,
dataMerger: dataMerger,
admitter: admitter,
logger: logger,
testHooks: testHooks,
}
}
// Execute handles receiving of the namespace replication task