From 7aaf62442ac30cf5739e8a37df762961c65303e9 Mon Sep 17 00:00:00 2001 From: Xun Jiang Date: Tue, 30 Jan 2024 22:28:59 +0800 Subject: [PATCH] Add `ParallelFilesUpload` for schedule creation. Modify restore-helper print information. Signed-off-by: Xun Jiang --- cmd/velero-restore-helper/velero-restore-helper.go | 4 ++-- pkg/cmd/cli/schedule/create.go | 6 ++++++ 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/cmd/velero-restore-helper/velero-restore-helper.go b/cmd/velero-restore-helper/velero-restore-helper.go index a6039381d..748f1e6c8 100644 --- a/cmd/velero-restore-helper/velero-restore-helper.go +++ b/cmd/velero-restore-helper/velero-restore-helper.go @@ -66,10 +66,10 @@ func done() bool { doneFile := filepath.Join("/restores", child.Name(), ".velero", os.Args[1]) if _, err := os.Stat(doneFile); os.IsNotExist(err) { - fmt.Printf("Not found: %s\n", doneFile) + fmt.Printf("The filesystem restore done file %s is not found yet. Retry later.\n", doneFile) return false } else if err != nil { - fmt.Fprintf(os.Stderr, "ERROR looking for %s: %s\n", doneFile, err) + fmt.Fprintf(os.Stderr, "ERROR looking filesystem restore done file %s: %s\n", doneFile, err) return false } diff --git a/pkg/cmd/cli/schedule/create.go b/pkg/cmd/cli/schedule/create.go index 32f277136..c9304e078 100644 --- a/pkg/cmd/cli/schedule/create.go +++ b/pkg/cmd/cli/schedule/create.go @@ -171,6 +171,12 @@ func (o *CreateOptions) Run(c *cobra.Command, f client.Factory) error { schedule.Spec.Template.ResourcePolicy = &v1.TypedLocalObjectReference{Kind: resourcepolicies.ConfigmapRefType, Name: o.BackupOptions.ResPoliciesConfigmap} } + if o.BackupOptions.ParallelFilesUpload > 0 { + schedule.Spec.Template.UploaderConfig = &api.UploaderConfigForBackup{ + ParallelFilesUpload: o.BackupOptions.ParallelFilesUpload, + } + } + if printed, err := output.PrintWithFormat(c, schedule); printed || err != nil { return err }