fix: fix threadsNum in AsyncBackup while handle backup

Signed-off-by: mlycore <[email protected]>
apache · Nov 14, 2023 · 12451b8 · 12451b8
1 parent 202e269
commit 12451b8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)