diff options
Diffstat (limited to 'weed/worker/tasks/base/task_definition.go')
| -rw-r--r-- | weed/worker/tasks/base/task_definition.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/worker/tasks/base/task_definition.go b/weed/worker/tasks/base/task_definition.go index 6689d9c81..5ebc2a4b6 100644 --- a/weed/worker/tasks/base/task_definition.go +++ b/weed/worker/tasks/base/task_definition.go @@ -26,14 +26,14 @@ type TaskDefinition struct { ConfigSpec ConfigSpec // Task creation - CreateTask func(params types.TaskParams) (types.TaskInterface, error) + CreateTask func(params *worker_pb.TaskParams) (types.Task, error) // Detection logic DetectionFunc func(metrics []*types.VolumeHealthMetrics, info *types.ClusterInfo, config TaskConfig) ([]*types.TaskDetectionResult, error) ScanInterval time.Duration // Scheduling logic - SchedulingFunc func(task *types.Task, running []*types.Task, workers []*types.Worker, config TaskConfig) bool + SchedulingFunc func(task *types.TaskInput, running []*types.TaskInput, workers []*types.WorkerData, config TaskConfig) bool MaxConcurrent int RepeatInterval time.Duration } |