fix(orchestration): avoid retry when finished (#10913)

2025-01-10 13:12:08 -03:00
parent a126f40bbe
commit 01acf9e700
2 changed files with 9 additions and 0 deletions
--- 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<void> {
+    if (this.hasFinished()) {
+      return
+    }
+
    await this.saveCheckpoint()
    await DistributedTransaction.keyValueStore.scheduleRetry(
      this,