From 57730f6a35061cee8272701ea9f7383d54e5e8a5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Gerg=C5=91=20M=C3=B3ricz?= <mo.geryy@gmail.com>
Date: Thu, 15 Aug 2024 18:58:07 +0200
Subject: [PATCH] priority changes

---
 apps/api/src/controllers/crawl.ts   | 4 ++--
 apps/api/src/services/queue-jobs.ts | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/apps/api/src/controllers/crawl.ts b/apps/api/src/controllers/crawl.ts
index 7c3e6328..4f3c5f22 100644
--- a/apps/api/src/controllers/crawl.ts
+++ b/apps/api/src/controllers/crawl.ts
@@ -134,7 +134,7 @@ export async function crawlController(req: Request, res: Response) {
           },
           opts: {
             jobId: uuid,
-            priority: 2,
+            priority: 20,
           }
         };
       })
@@ -153,7 +153,7 @@ export async function crawlController(req: Request, res: Response) {
         origin: req.body.origin ?? defaultOrigin,
         crawl_id: id,
       }, {
-        priority: 1, // prioritize request 0 of crawl jobs same as scrape jobs
+        priority: 15, // prioritize request 0 of crawl jobs same as scrape jobs
       });
       await addCrawlJob(id, job.id);
     }
diff --git a/apps/api/src/services/queue-jobs.ts b/apps/api/src/services/queue-jobs.ts
index 0f0d2c99..3099da68 100644
--- a/apps/api/src/services/queue-jobs.ts
+++ b/apps/api/src/services/queue-jobs.ts
@@ -9,7 +9,7 @@ export async function addScrapeJob(
   jobId: string = uuidv4(),
 ): Promise<Job> {
   return await getScrapeQueue().add(jobId, webScraperOptions, {
-    priority: webScraperOptions.crawl_id ? 2 : 1,
+    priority: webScraperOptions.crawl_id ? 20 : 10,
     ...options,
     jobId,
   });