fix: make sync jobs project-specific

panoratech · Dec 24, 2024 · 3989319 · 3989319
1 parent 7c28b0b
commit 3989319
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/packages/api/src/@core/@core-services/queues/shared.service.ts b/packages/api/src/@core/@core-services/queues/shared.service.ts
@@ -21,7 +21,6 @@ export class BullQueueService {
   ) {}
 
   // getters
-
   getRealtimeWebhookReceiver() {
     return this.realTimeWebhookQueue;
   }

diff --git a/packages/api/src/@core/sync/sync.service.ts b/packages/api/src/@core/sync/sync.service.ts
@@ -108,7 +108,7 @@ export class CoreSyncService {
                                   this.convertIntervalToCron(Number(interval));
 
                                 await this.bullQueueService.queueSyncJob(
-                                  `${vertical}-sync-${commonObject}s`,
+                                  `${vertical}-sync-${commonObject}s-${project.id_project}`,
                                   {
                                     projectId: project.id_project,
                                     vertical,
@@ -143,7 +143,7 @@ export class CoreSyncService {
                         getCommonObjectsForVertical(vertical);
                       for (const commonObject of commonObjects) {
                         await this.bullQueueService.removeRepeatableJob(
-                          `${vertical}-sync-${commonObject}s`,
+                          `${vertical}-sync-${commonObject}s-${project.id_project}`,
                         );
                       }
                     }
-Original file line number
+Diff line change
@@ Expand Up / @@ -21,7 +21,6 @@ export class BullQueueService { @@
       ) {}
       // getters
       getRealtimeWebhookReceiver() {
         return this.realTimeWebhookQueue;
       }
@@ Expand Down @@