diff options
| -rw-r--r-- | devtools/cmd/seeddb/main.go | 2 | ||||
| -rw-r--r-- | internal/database/database.go | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/devtools/cmd/seeddb/main.go b/devtools/cmd/seeddb/main.go index 3c2c96b8..623b37b4 100644 --- a/devtools/cmd/seeddb/main.go +++ b/devtools/cmd/seeddb/main.go @@ -112,7 +112,7 @@ func run(ctx context.Context, db *database.DB, proxyURL string) error { } g, gctx := errgroup.WithContext(ctx) - g.SetLimit(10) + g.SetLimit(5) f := &worker.Fetcher{ ProxyClient: proxyClient, SourceClient: sourceClient, diff --git a/internal/database/database.go b/internal/database/database.go index bcb7c09a..5fd3af9e 100644 --- a/internal/database/database.go +++ b/internal/database/database.go @@ -246,7 +246,7 @@ func (db *DB) transactWithRetry(ctx context.Context, opts *sql.TxOptions, txFunc defer derrors.Wrap(&err, "transactWithRetry(%v)", opts) // Retry on serialization failure, up to some max. // See https://www.postgresql.org/docs/11/transaction-iso.html. - const maxRetries = 10 + const maxRetries = 20 sleepDur := 125 * time.Millisecond for i := 0; i <= maxRetries; i++ { err = db.transact(ctx, opts, txFunc) |