admin: Refactor task destination planning (#7063)

* refactor planning into task detection

* refactoring worker tasks

* refactor

* compiles, but only balance task is registered

* compiles, but has nil exception

* avoid nil logger

* add back ec task

* setting ec log directory

* implement balance and vacuum tasks

* EC tasks will no longer fail with "file not found" errors

* Use ReceiveFile API to send locally generated shards

* distributing shard files and ecx,ecj,vif files

* generate .ecx files correctly

* do not mount all possible EC shards (0-13) on every destination

* use constants

* delete all replicas

* rename files

* pass in volume size to tasks

1 files changed, 3 insertions, 3 deletions

diff --git a/weed/worker/tasks/base/generic_components.go b/weed/worker/tasks/base/generic_components.go
index 27ad1bb29..0a41bbd76 100644
--- a/weed/worker/tasks/base/generic_components.go
+++ b/weed/worker/tasks/base/generic_components.go
@@ -58,7 +58,7 @@ func (s *GenericScheduler) GetTaskType() types.TaskType {
 }
 
 // CanScheduleNow determines if a task can be scheduled using the task definition's function
-func (s *GenericScheduler) CanScheduleNow(task *types.Task, runningTasks []*types.Task, availableWorkers []*types.Worker) bool {
+func (s *GenericScheduler) CanScheduleNow(task *types.TaskInput, runningTasks []*types.TaskInput, availableWorkers []*types.WorkerData) bool {
 	if s.taskDef.SchedulingFunc == nil {
 		return s.defaultCanSchedule(task, runningTasks, availableWorkers)
 	}
@@ -66,7 +66,7 @@ func (s *GenericScheduler) CanScheduleNow(task *types.Task, runningTasks []*type
 }
 
 // defaultCanSchedule provides default scheduling logic
-func (s *GenericScheduler) defaultCanSchedule(task *types.Task, runningTasks []*types.Task, availableWorkers []*types.Worker) bool {
+func (s *GenericScheduler) defaultCanSchedule(task *types.TaskInput, runningTasks []*types.TaskInput, availableWorkers []*types.WorkerData) bool {
 	if !s.taskDef.Config.IsEnabled() {
 		return false
 	}
@@ -103,7 +103,7 @@ func (s *GenericScheduler) defaultCanSchedule(task *types.Task, runningTasks []*
 }
 
 // GetPriority returns the priority for this task
-func (s *GenericScheduler) GetPriority(task *types.Task) types.TaskPriority {
+func (s *GenericScheduler) GetPriority(task *types.TaskInput) types.TaskPriority {
 	return task.Priority
 }