mirror of
https://github.com/webrecorder/browsertrix-crawler.git
synced 2025-10-19 14:33:17 +00:00
Backport pending list never being reprocessed (#438)
Backport of #433 to 0.12.x. Bump version to 0.12.2
This commit is contained in:
parent
dd7b926d87
commit
9ba0b9edc1
2 changed files with 3 additions and 4 deletions
|
@ -1,6 +1,6 @@
|
|||
{
|
||||
"name": "browsertrix-crawler",
|
||||
"version": "0.12.1",
|
||||
"version": "0.12.2",
|
||||
"main": "browsertrix-crawler",
|
||||
"type": "module",
|
||||
"repository": "https://github.com/webrecorder/browsertrix-crawler",
|
||||
|
|
|
@ -496,7 +496,7 @@ return 0;
|
|||
const res = await this.redis.hlen(this.pkey);
|
||||
|
||||
// reset pendings
|
||||
if (res > 0 && !this._lastSize) {
|
||||
if (res > 0 && !(await this.queueSize())) {
|
||||
await this.resetPendings();
|
||||
}
|
||||
|
||||
|
@ -546,8 +546,7 @@ return 0;
|
|||
}
|
||||
|
||||
async queueSize() {
|
||||
this._lastSize = await this.redis.zcard(this.qkey);
|
||||
return this._lastSize;
|
||||
return await this.redis.zcard(this.qkey);
|
||||
}
|
||||
|
||||
async logError(error) {
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue