1033
currentRunInfo.RunID,
1034
)
1035
>
case chasm.BusinessIDConflictPolicyTerminateExisting:
chasm_engine.go
1036
>
// TODO: handle BusinessIDConflictPolicyTerminateExisting and update TestNewExecution_ConflictPolicy_TerminateExisting.
1037
>
//
1038
>
// Today's state-based replication logic can not existly handle this policy correctly
1039
>
// (or any operation that close and starts a new run in one transaction).
1040
>
// The termination and creation of new run can not be replicated transactionally.
1041
>
//
1042
>
// The main blocker is that state-based replication works on the current state,
1043
>
// and we may have a chain of runs all created via TerminateExisting policy, meaning
1044
>
// replication has to replicated all of them transactionally.
1045
>
// We need a way to break this chain into consistent pieces and replicate them one by one.
1046
>
return chasm.StartExecutionResult{}, serviceerror.NewUnimplemented("ID Conflict Policy Terminate Existing is not yet supported")
1047
case chasm.BusinessIDConflictPolicyUseExisting:
1048
existingExecutionRef := newExecutionParams.executionRef