fix(orchestration): avoid retry when finished

medusajs · Jan 10, 2025 · 8b14fe6 · 8b14fe6
1 parent 8650e61
commit 8b14fe6
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/.changeset/chilled-schools-collect.md b/.changeset/chilled-schools-collect.md
@@ -0,0 +1,5 @@
+---
+"@medusajs/orchestration": patch
+---
+
+fix(orchestration): avoid retry when finished
diff --git a/packages/core/orchestration/src/transaction/distributed-transaction.ts b/packages/core/orchestration/src/transaction/distributed-transaction.ts
@@ -248,6 +248,10 @@ class DistributedTransaction extends EventEmitter {
     step: TransactionStep,
     interval: number
   ): Promise<void> {
+    if (this.hasFinished()) {
+      return
+    }
+
     await this.saveCheckpoint()
     await DistributedTransaction.keyValueStore.scheduleRetry(
       this,