Skip to content

Commit cfe4791

Browse files
committed
fix: 移除失败的命令
1 parent a861e27 commit cfe4791

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

cmd/common/uploader_service.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -122,6 +122,9 @@ func (u *UploaderService) run() {
122122
if err := commandBackend.BulkSave(cmdList); err != nil {
123123
logger.Errorf("Uploader service command bulk save err: %s", err)
124124
maxRetry++
125+
if maxRetry > 5 {
126+
cmdList = cmdList[1:]
127+
}
125128
continue
126129
}
127130
logger.Infof("Uploader service command backend %s upload %d commands",

0 commit comments

Comments
 (0)