Iyeoluwads/firecrawl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(queue-worker): log jobs correctly

Browse Source
This commit is contained in:
Gergő Móricz
2024-08-15 19:27:15 +02:00
parent dad9d353d9
commit 965a5817d1
1 changed files with 35 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/api/src/services/queue-worker.ts
+2 -2
View File
@@ -149,6 +149,7 @@ async function processJob(job: Job, token: string) {
await callWebhook(job.data.team_id, job.id as string, data); await callWebhook(job.data.team_id, job.id as string, data);
} }
if (job.data.crawl_id) {
await logJob({ await logJob({
job_id: job.id as string, job_id: job.id as string,
success: success, success: success,
@@ -165,7 +166,6 @@ async function processJob(job: Job, token: string) {
crawl_id: job.data.crawl_id, crawl_id: job.data.crawl_id,
}); });
if (job.data.crawl_id) {
await addCrawlJobDone(job.data.crawl_id, job.id); await addCrawlJobDone(job.data.crawl_id, job.id);
const sc = await getCrawl(job.data.crawl_id) as StoredCrawl; const sc = await getCrawl(job.data.crawl_id) as StoredCrawl;
@@ -301,6 +301,7 @@ async function processJob(job: Job, token: string) {
await callWebhook(job.data.team_id, job.data.crawl_id ?? job.id as string, data); await callWebhook(job.data.team_id, job.data.crawl_id ?? job.id as string, data);
} }
if (job.data.crawl_id) {
await logJob({ await logJob({
job_id: job.id as string, job_id: job.id as string,
success: false, success: false,
@@ -320,7 +321,6 @@ async function processJob(job: Job, token: string) {
crawl_id: job.data.crawl_id, crawl_id: job.data.crawl_id,
}); });
if (job.data.crawl_id) {
const sc = await getCrawl(job.data.crawl_id); const sc = await getCrawl(job.data.crawl_id);
await logJob({ await logJob({