From 12451b841f7082da801e06244520a64d75a28c38 Mon Sep 17 00:00:00 2001 From: mlycore Date: Tue, 14 Nov 2023 10:32:33 +0800 Subject: [PATCH] fix: fix threadsNum in AsyncBackup while handle backup Signed-off-by: mlycore --- pitr/agent/internal/handler/backup.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pitr/agent/internal/handler/backup.go b/pitr/agent/internal/handler/backup.go index d3e9817f..dfb1d294 100644 --- a/pitr/agent/internal/handler/backup.go +++ b/pitr/agent/internal/handler/backup.go @@ -50,7 +50,7 @@ func Backup(ctx *fiber.Ctx) error { return fmt.Errorf("add instance failed, err wrap: %w", err) } - backupID, err := pkg.OG.AsyncBackup(in.DnBackupPath, in.Instance, in.DnBackupMode, 1, in.DBPort) + backupID, err := pkg.OG.AsyncBackup(in.DnBackupPath, in.Instance, in.DnBackupMode, in.DnThreadsNum, in.DBPort) if err != nil { efmt := "pkg.OG.AsyncBackup[path=%s,instance=%s,mode=%s] failure, err wrap: %w" return fmt.Errorf(efmt, in.DnBackupPath, in.Instance, in.DnBackupMode, err)