fix(crawl-status): improve finished checking
This commit is contained in:
@@ -13,6 +13,7 @@ import {
|
|||||||
getDoneJobsOrderedLength,
|
getDoneJobsOrderedLength,
|
||||||
getThrottledJobs,
|
getThrottledJobs,
|
||||||
isCrawlFinished,
|
isCrawlFinished,
|
||||||
|
isCrawlFinishedLocked,
|
||||||
} from "../../lib/crawl-redis";
|
} from "../../lib/crawl-redis";
|
||||||
import { getScrapeQueue } from "../../services/queue-service";
|
import { getScrapeQueue } from "../../services/queue-service";
|
||||||
import {
|
import {
|
||||||
@@ -117,7 +118,7 @@ export async function crawlStatusController(
|
|||||||
sc.cancelled
|
sc.cancelled
|
||||||
? "cancelled"
|
? "cancelled"
|
||||||
: validJobStatuses.every((x) => x[1] === "completed") &&
|
: validJobStatuses.every((x) => x[1] === "completed") &&
|
||||||
await isCrawlFinished(req.params.jobId)
|
(await isCrawlFinishedLocked(req.params.jobId) || await isCrawlFinished(req.params.jobId))
|
||||||
? "completed"
|
? "completed"
|
||||||
: "scraping";
|
: "scraping";
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user