From 84a0b8f4954b146890727548a6e69b7cadad43ba Mon Sep 17 00:00:00 2001 From: Ahmed Bouhuolia Date: Thu, 29 Aug 2024 10:05:38 +0200 Subject: [PATCH] fix: re-schedule the jobs have date from the current moment --- packages/server/src/services/Inventory/Inventory.ts | 8 +++++++- .../src/subscribers/SaleInvoices/WriteJournalEntries.ts | 1 - 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/packages/server/src/services/Inventory/Inventory.ts b/packages/server/src/services/Inventory/Inventory.ts index 980ace79a..9a92685ca 100644 --- a/packages/server/src/services/Inventory/Inventory.ts +++ b/packages/server/src/services/Inventory/Inventory.ts @@ -157,7 +157,6 @@ export default class InventoryService { ...commonJobsQuery, 'data.startingDate': { $gte: startingDate }, }); - // If the depends jobs cleared. if (dependsJobs.length === 0) { await agenda.schedule( @@ -174,6 +173,13 @@ export default class InventoryService { events.inventory.onComputeItemCostJobScheduled, { startingDate, itemId, tenantId } as IInventoryItemCostScheduledPayload ); + } else { + // Re-schedule the jobs that have higher date from current moment. + await Promise.all( + dependsJobs.map((job) => + job.schedule(config.scheduleComputeItemCost).save() + ) + ); } } diff --git a/packages/server/src/subscribers/SaleInvoices/WriteJournalEntries.ts b/packages/server/src/subscribers/SaleInvoices/WriteJournalEntries.ts index 14a160253..4b1eab698 100644 --- a/packages/server/src/subscribers/SaleInvoices/WriteJournalEntries.ts +++ b/packages/server/src/subscribers/SaleInvoices/WriteJournalEntries.ts @@ -6,7 +6,6 @@ import { ISaleInvoiceEditedPayload, } from '@/interfaces'; import { SaleInvoiceGLEntries } from '@/services/Sales/Invoices/InvoiceGLEntries'; -import { runAfterTransaction } from '@/services/UnitOfWork/TransactionsHooks'; @Service() export default class SaleInvoiceWriteGLEntriesSubscriber {