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 {