diff options
| author | John Cai <jcai@gitlab.com> | 2020-02-11 19:36:32 +0300 |
|---|---|---|
| committer | John Cai <jcai@gitlab.com> | 2020-02-11 19:36:32 +0300 |
| commit | 6253d92ab036f43081aa1f0707657fca6f4fc650 (patch) | |
| tree | a87fddc64b9674f935aa340d656853fd77b67941 /cmd | |
| parent | 974010a7802b73674d06288dda327dff69fb7e82 (diff) | |
| parent | 7252714913c4fb81234f4bf1f2ff5a31ba255e6b (diff) | |
Merge branch 'jc-repl-job-errors' into 'master'
Praefect replicator to mark job as failed and retry failed jobs
Closes #2138
See merge request gitlab-org/gitaly!1804
Diffstat (limited to 'cmd')
| -rw-r--r-- | cmd/praefect/main.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/cmd/praefect/main.go b/cmd/praefect/main.go index a0868f36d..e74e09c05 100644 --- a/cmd/praefect/main.go +++ b/cmd/praefect/main.go @@ -33,6 +33,7 @@ import ( "fmt" "os" "strings" + "time" "github.com/sirupsen/logrus" "gitlab.com/gitlab-org/gitaly/internal/bootstrap" @@ -190,7 +191,9 @@ func run(cfgs []starter.Config, conf config.Config) error { } go func() { serverErrors <- b.Wait() }() - go func() { serverErrors <- repl.ProcessBacklog(ctx) }() + go func() { + serverErrors <- repl.ProcessBacklog(ctx, praefect.ExpBackoffFunc(1*time.Second, 5*time.Minute)) + }() go coordinator.FailoverRotation() |