AI/reader
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/jina-ai/reader synced 2025-08-12 09:59:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: wait-for-selector stalling process

Browse Source
This commit is contained in:
Yanlong Wang 2025-05-07 22:38:50 +08:00
parent da1098f38d
commit 7bc70a1955
No known key found for this signature in database
GPG Key ID: C0A623C0BADF9F37
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/services/puppeteer.ts
View File

@ -1210,7 +1210,6 @@ export class PuppeteerControl extends AsyncService {
} }
await Promise.race([Promise.allSettled([...pageScriptEvaluations, ...frameScriptEvaluations]), delayPromise]) await Promise.race([Promise.allSettled([...pageScriptEvaluations, ...frameScriptEvaluations]), delayPromise])
.catch(() => void 0); .catch(() => void 0);
finalizationPromise = doFinalization();
return stuff; return stuff;
}); });
if (options.waitForSelector) { if (options.waitForSelector) {
@ -1232,16 +1231,16 @@ export class PuppeteerControl extends AsyncService {
}); });
return p as any; return p as any;
}); });
finalizationPromise = Promise.allSettled([waitForPromise, gotoPromise]).then(doFinalization);
} else {
finalizationPromise = gotoPromise.then(doFinalization);
} }
try { try {
let lastHTML = snapshot?.html; let lastHTML = snapshot?.html;
while (true) { while (true) {
const ckpt = [nextSnapshotDeferred.promise, gotoPromise]; const ckpt = [nextSnapshotDeferred.promise, waitForPromise ?? gotoPromise];
if (waitForPromise) {
ckpt.push(waitForPromise);
}
if (options.minIntervalMs) { if (options.minIntervalMs) {
ckpt.push(delay(options.minIntervalMs)); ckpt.push(delay(options.minIntervalMs));
} }