196
shardID int32,
197
workflowSnapshot *p.InternalWorkflowSnapshot,
199
>
lastWriteVersion := workflowSnapshot.LastWriteVersion
200
>
workflowID := workflowSnapshot.WorkflowID
201
>
namespaceID := workflowSnapshot.NamespaceID
202
>
runID := workflowSnapshot.ExecutionState.RunId
203
>
namespaceIDBytes, err := primitives.ParseUUID(namespaceID)
204
>
if err != nil {
205
return err
206
}
208
>
if err != nil {
209
return err
210
}
211
212
// TODO Is there a way to modify the various map tables without fear of other people adding rows after we delete, without locking the executions row?
214
>
tx,
215
>
shardID,
216
>
namespaceIDBytes,
217
>
workflowID,
218
>
runIDBytes,
219
>
workflowSnapshot.Condition,
220
>
workflowSnapshot.DBRecordVersion,
221
>
); err != nil {
222
switch err.(type) {
223
case *p.WorkflowConditionFailedError, *p.ConditionFailedError: