logger log.Logger,
metricsHandler metrics.Handler,
return &ExecutableTaskTrackerImpl{
logger: logger,
metricsHandler: metricsHandler,
exclusiveHighWatermarkInfo: nil,
taskQueue: list.New(),
}
}
// TrackTasks add tasks for tracking, return valid tasks (dedup)