1
This commit is contained in:
parent
af794c8235
commit
ce0a246f74
@ -43,15 +43,19 @@ class Erc721Refresher extends BaseService {
|
||||
throw err;
|
||||
}
|
||||
if (rows.length > 0) {
|
||||
this.progInfo['pendingCount'] = rows.length;
|
||||
await utils.serial(
|
||||
rows,
|
||||
async (row) => {
|
||||
await this.refresh(row);
|
||||
--this.progInfo['pendingCount'];
|
||||
}
|
||||
);
|
||||
} else {
|
||||
this.lastIdx = BigInt(0);
|
||||
}
|
||||
++this.progInfo['refreshedCount'];
|
||||
this.progInfo['pendingCount'] = 0;
|
||||
} catch (err) {
|
||||
log.error(logHead + err);
|
||||
await utils.sleep(5000 + utils.randRange(1000, 3000));
|
||||
|
Loading…
x
Reference in New Issue
Block a user