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

fix/added unkwown status to job filter

Browse Source
This commit is contained in:
rafaelsideguide 2024-10-11 15:40:29 -03:00
parent ca51521625
commit 2d3d7c827a
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/api/src/controllers/v0/crawl-status.ts
View File

@ -60,7 +60,7 @@ export async function crawlStatusController(req: Request, res: Response) {
})); }));
// Filter out failed jobs // Filter out failed jobs
jobsWithStatuses = jobsWithStatuses.filter(x => x.status !== "failed"); jobsWithStatuses = jobsWithStatuses.filter(x => x.status !== "failed" && x.status !== "unknown");
// Sort jobs by timestamp // Sort jobs by timestamp
jobsWithStatuses.sort((a, b) => a.job.timestamp - b.job.timestamp); jobsWithStatuses.sort((a, b) => a.job.timestamp - b.job.timestamp);

2
apps/api/src/controllers/v1/crawl-status-ws.ts
View File

@ -101,7 +101,7 @@ async function crawlStatusWS(ws: WebSocket, req: RequestWithAuth<CrawlStatusPara
// filter out failed jobs // filter out failed jobs
jobIDs = jobIDs.filter(id => !jobStatuses.some(status => status[0] === id && status[1] === "failed")); jobIDs = jobIDs.filter(id => !jobStatuses.some(status => status[0] === id && status[1] === "failed"));
// filter the job statues // filter the job statues
jobStatuses = jobStatuses.filter(x => x[1] !== "failed"); jobStatuses = jobStatuses.filter(x => x[1] !== "failed" && x[1] !== "unknown");
const status: Exclude<CrawlStatusResponse, ErrorResponse>["status"] = sc.cancelled ? "cancelled" : jobStatuses.every(x => x[1] === "completed") ? "completed" : "scraping"; const status: Exclude<CrawlStatusResponse, ErrorResponse>["status"] = sc.cancelled ? "cancelled" : jobStatuses.every(x => x[1] === "completed") ? "completed" : "scraping";
const doneJobs = await getJobs(doneJobIDs); const doneJobs = await getJobs(doneJobIDs);
const data = doneJobs.map(x => x.returnvalue); const data = doneJobs.map(x => x.returnvalue);