From 185332fa28b92d03aa246f6722d6e5cd91b3d4d4 Mon Sep 17 00:00:00 2001 From: Jian Qiu Date: Mon, 22 Sep 2025 09:48:20 +0800 Subject: [PATCH] fix: host backup task worker limit (#23347) 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"`