AI/firecrawl
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/mendableai/firecrawl synced 2025-08-12 20:39:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(log_job): infinite loop

Browse Source
This commit is contained in:
Móricz Gergő 2024-11-28 08:49:03 +01:00
parent 943bbae88d
commit 60ea97c51c
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
apps/api/src/services/logging/log_job.ts
View File

@ -42,7 +42,8 @@ export async function logJob(job: FirecrawlJob, force: boolean = false) {
}; };
if (force) { if (force) {
while (true) { let i = 0, done = false;
while (i++ <= 10) {
try { try {
const { error } = await supabase_service const { error } = await supabase_service
.from("firecrawl_jobs") .from("firecrawl_jobs")
@ -51,6 +52,7 @@ export async function logJob(job: FirecrawlJob, force: boolean = false) {
logger.error("Failed to log job due to Supabase error -- trying again", { error, scrapeId: job.job_id }); logger.error("Failed to log job due to Supabase error -- trying again", { error, scrapeId: job.job_id });
await new Promise<void>((resolve) => setTimeout(() => resolve(), 75)); await new Promise<void>((resolve) => setTimeout(() => resolve(), 75));
} else { } else {
done = true;
break; break;
} }
} catch (error) { } catch (error) {
@ -58,7 +60,11 @@ export async function logJob(job: FirecrawlJob, force: boolean = false) {
await new Promise<void>((resolve) => setTimeout(() => resolve(), 75)); await new Promise<void>((resolve) => setTimeout(() => resolve(), 75));
} }
} }
logger.debug("Job logged successfully!", { scrapeId: job.job_id }); if (done) {
logger.debug("Job logged successfully!", { scrapeId: job.job_id });
} else {
logger.error("Failed to log job!", { scrapeId: job.job_id });
}
} else { } else {
const { error } = await supabase_service const { error } = await supabase_service
.from("firecrawl_jobs") .from("firecrawl_jobs")