Bump the limit on stored bad records to 500
parent
d189912bcf
commit
693ae1ba0a
|
@ -132,7 +132,7 @@ func (c *Consumer) runOnce(ctx context.Context) error {
|
|||
switch header.Op {
|
||||
case 1:
|
||||
if err := c.processMessage(ctx, header.Type, r, first); err != nil {
|
||||
const maxBadRecords = 100
|
||||
const maxBadRecords = 500
|
||||
var count int64
|
||||
if err2 := c.db.Model(&BadRecord{}).Where(&BadRecord{PDS: c.remote.ID}).Count(&count).Error; err2 != nil {
|
||||
return err
|
||||
|
|
Loading…
Reference in New Issue