Skip to content

Commit

Permalink
annotate backup throttler func
Browse files Browse the repository at this point in the history
  • Loading branch information
chengjoey committed Oct 12, 2021
1 parent d42b398 commit e74dcd7
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion modules/pipeline/pipengine/reconciler/define.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ type Reconciler struct {
dbClient *dbclient.Client

QueueManager types.QueueManager
TaskThrottler throttler.Throttler
TaskThrottler throttler.Throttler // TODO remove the throttler.Throttler, after 1.0 iteration throttler is not necessary

// processingTasks store task id which is in processing
processingTasks sync.Map
Expand Down
2 changes: 1 addition & 1 deletion modules/pipeline/pipengine/reconciler/throttler.go
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ func (r *Reconciler) loadThrottler(ctx context.Context) error {
logrus.Warnf("reconciler: failed to load throttler, ignore, import err: %v", err)
// load from database

r.continueBackupThrottler(ctx)
//r.continueBackupThrottler(ctx)
return nil
}

Expand Down

0 comments on commit e74dcd7

Please sign in to comment.