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

fix: tweak health check

Browse Source
This commit is contained in:
Yanlong Wang 2024-04-30 18:56:46 +08:00
parent 528b3e5fed
commit 55b954ffeb
No known key found for this signature in database
GPG Key ID: C0A623C0BADF9F37
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
backend/functions/src/services/puppeteer.ts
View File

@ -151,21 +151,24 @@ export class PuppeteerControl extends AsyncService {
@maxConcurrency(1)
async healthCheck() {
const healthyPage = await Promise.race([this.pagePool.acquire(3), delay(60_000).then(() => null)]).catch((err) => {
this.logger.error(`Health check failed`, { err: marshalErrorLike(err) });
this.pagePool.max += 1;
const healthyPage = await this.pagePool.acquire(3).catch((err) => {
this.logger.warn(`Health check failed`, { err: marshalErrorLike(err) });
return null;
});
this.pagePool.max -= 1;
if (healthyPage) {
this.pagePool.release(healthyPage);
return;
}
this.logger.warn(`Health check failed, trying to clean up.`);
this.logger.warn(`Trying to clean up...`);
await this.pagePool.clear();
this.browser.process()?.kill('SIGKILL');
Reflect.deleteProperty(this, 'browser');
this.emit('crippled');
this.logger.warn(`Browser killed`);
}
async newPage() {