Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tom@curii.com>
txPending := 0
flush := func(final bool) error {
err := tx.Commit()
txPending := 0
flush := func(final bool) error {
err := tx.Commit()
+ if err != nil && ctx.Err() == nil {
tx.Rollback()
return err
}
tx.Rollback()
return err
}
where uuid=$4`,
repl, thresholdStr, classes, coll.UUID)
if err != nil {
where uuid=$4`,
repl, thresholdStr, classes, coll.UUID)
if err != nil {
- if err != context.Canceled {
bal.logf("%s: update failed: %s", coll.UUID, err)
}
continue
bal.logf("%s: update failed: %s", coll.UUID, err)
}
continue