From b3d3c8de66e6bb554a89a571cfe3ac9c7d80db48 Mon Sep 17 00:00:00 2001
From: Zexi Li <zexi.li@icloud.com>
Date: Mon, 25 Oct 2021 11:55:43 +0800
Subject: [PATCH] fix(baremetal): TaskWorkerCount options not init

---
 pkg/baremetal/tasks/worker.go | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/pkg/baremetal/tasks/worker.go b/pkg/baremetal/tasks/worker.go
index 768c2d5f28..700e505495 100644
--- a/pkg/baremetal/tasks/worker.go
+++ b/pkg/baremetal/tasks/worker.go
@@ -24,16 +24,16 @@ import (
 	"yunion.io/x/log"
 
 	"yunion.io/x/onecloud/pkg/appsrv"
+	"yunion.io/x/onecloud/pkg/baremetal/options"
 	"yunion.io/x/onecloud/pkg/mcclient/modules"
 )
 
 var baremetalTaskWorkerMan *appsrv.SWorkerManager
 
-func init() {
-	baremetalTaskWorkerMan = appsrv.NewWorkerManager("BaremetalTaskWorkerManager", 4, 1024, false)
-}
-
 func GetWorkManager() *appsrv.SWorkerManager {
+	if baremetalTaskWorkerMan == nil {
+		baremetalTaskWorkerMan = appsrv.NewWorkerManager("BaremetalTaskWorkerManager", options.Options.TaskWorkerCount, 1024, false)
+	}
 	return baremetalTaskWorkerMan
 }
 
@@ -62,7 +62,7 @@ func ExecuteTask(task ITask, args interface{}) {
 		task: task,
 		args: args,
 	}
-	baremetalTaskWorkerMan.Run(t, nil, nil)
+	GetWorkManager().Run(t, nil, nil)
 }
 
 func executeTask(task ITask, args interface{}) {