fix: hashed-worker-manager nil pointer panic (#21887)

Co-authored-by: Qiu Jian <[email protected]>
yunionio · Dec 23, 2024 · 589343e · 589343e
1 parent 290626c
commit 589343e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/cloudcommon/db/taskman/coordinator.go b/pkg/cloudcommon/db/taskman/coordinator.go
@@ -77,13 +77,13 @@ func registerTaskAndWorkerMan(task interface{}, workerMan interface{}) {
 	taskType := reflect.Indirect(reflect.ValueOf(task)).Type()
 	taskTable[taskName] = taskType
 	// log.Infof("Task %s registerd", taskName)
-	if workerMan != nil {
+	if workerMan != nil && !gotypes.IsNil(workerMan) {
 		taskWorkerMap[taskName] = workerMan
 	}
 }
 
 func RegisterTask(task interface{}) {
-	RegisterTaskAndWorker(task, nil)
+	registerTaskAndWorkerMan(task, nil)
 }
 
 func isTaskExist(taskName string) bool {