Skip to content

Commit 67b2f12

Browse files
author
anton.voskresensky
committed
add parallel snapshots
1 parent 7367dfd commit 67b2f12

File tree

2 files changed

+168
-40
lines changed

2 files changed

+168
-40
lines changed

commands/snapshot-manual.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ func runSnapshotManual(cmd *cobra.Command, args []string) error {
161161
indicesStr := strings.Join(matchingIndices, ",")
162162
logger.Info(fmt.Sprintf("Creating snapshot %s", snapshotName))
163163
logger.Info(fmt.Sprintf("Snapshot indices %s", indicesStr))
164-
err = utils.CreateSnapshotWithRetry(client, snapshotName, indicesStr, repoToUse, cfg.GetKubeNamespace(), today, madisonClient, logger, 60*time.Second, cfg.GetMaxConcurrentSnapshots())
164+
err = utils.CreateSnapshotWithRetry(client, snapshotName, indicesStr, repoToUse, cfg.GetKubeNamespace(), today, madisonClient, logger, 60*time.Second, cfg.GetMaxConcurrentSnapshots(), 0)
165165
if err != nil {
166166
logger.Error(fmt.Sprintf("Failed to create snapshot after retries snapshot=%s error=%v", snapshotName, err))
167167
return err

0 commit comments

Comments
 (0)