Generate txn id for each event

temporalio · Aug 14, 2023 · 691a361 · 691a361
1 parent aa5c3db
commit 691a361
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/service/history/ndc/history_replicator.go b/service/history/ndc/history_replicator.go
@@ -739,7 +739,7 @@ func (r *HistoryReplicatorImpl) applyNonStartEventsToNonCurrentBranchWithoutCont
 		return err
 	}
 
-	transactionID, err := r.shard.GenerateTaskID()
+	transactionIDs, err := r.shard.GenerateTaskIDs(len(task.getEvents()))
 	if err != nil {
 		return err
 	}
@@ -752,7 +752,7 @@ func (r *HistoryReplicatorImpl) applyNonStartEventsToNonCurrentBranchWithoutCont
 			RunID:       task.getExecution().GetRunId(),
 			BranchToken: versionHistory.GetBranchToken(),
 			PrevTxnID:   0, // TODO @wxing1292 events chaining will not work for backfill case
-			TxnID:       transactionID,
+			TxnID:       transactionIDs[i],
 			Events:      events,
 		}
 	}