diff --git a/.changeset/chilled-schools-collect.md b/.changeset/chilled-schools-collect.md new file mode 100644 index 0000000000..7b141e1602 --- /dev/null +++ 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 index 8c84add8b8..afa5d280eb 100644 --- a/packages/core/orchestration/src/transaction/distributed-transaction.ts +++ b/packages/core/orchestration/src/transaction/distributed-transaction.ts @@ -244,6 +244,10 @@ class DistributedTransaction extends EventEmitter { step: TransactionStep, interval: number ): Promise { + if (this.hasFinished()) { + return + } + await this.saveCheckpoint() await DistributedTransaction.keyValueStore.scheduleRetry( this,