From 93a8a95ce2d3e5ac193fedd84c9cc144913cb6b9 Mon Sep 17 00:00:00 2001 From: Jian Qiu Date: Mon, 22 Sep 2025 09:48:03 +0800 Subject: [PATCH] fix: host backup task worker limit (#23349) Co-authored-by: Qiu Jian --- pkg/hostman/hostutils/hostutils.go | 2 +- pkg/hostman/options/options.go | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) 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"`