diff --git a/pkg/hostman/hostutils/hostutils.go b/pkg/hostman/hostutils/hostutils.go index d437b6066e..c6d11192c4 100644 --- a/pkg/hostman/hostutils/hostutils.go +++ b/pkg/hostman/hostutils/hostutils.go @@ -312,7 +312,7 @@ func initImageCacheWorkerManager() { } func initBackupWorkerManager() { - backupW = workmanager.NewWorkManger("BackupDelayTaskWorkers", TaskFailed, TaskComplete, options.HostOptions.DefaultRequestWorkerCount) + backupW = workmanager.NewWorkManger("BackupDelayTaskWorkers", TaskFailed, TaskComplete, options.HostOptions.BackupTaskWorkerCount) } func InitWorkerManagerWithCount(count int) { diff --git a/pkg/hostman/options/options.go b/pkg/hostman/options/options.go index 45ff9c7190..39b5c1c7e5 100644 --- a/pkg/hostman/options/options.go +++ b/pkg/hostman/options/options.go @@ -171,6 +171,7 @@ type SHostOptions struct { MaxReservedMemory int `default:"10240" help:"host reserved memory"` + BackupTaskWorkerCount int `default:"2" help:"backup task worker count"` DefaultRequestWorkerCount int `default:"8" help:"default request worker count"` ImageCacheWorkerCount int `default:"8" help:"default request worker count"` ContainerStartWorkerCount int `default:"1" help:"container start worker count"`