55
}
56
58
>
shardID := rand.Int31()
59
>
namespaceID := primitives.NewUUID()
60
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
61
>
runID := primitives.NewUUID()
62
>
initiatedID := rand.Int63()
63
>
64
>
requestCancel := s.newRandomExecutionRequestCancelRow(shardID, namespaceID, workflowID, runID, initiatedID)
65
>
result, err := s.store.ReplaceIntoRequestCancelInfoMaps(newExecutionContext(), []sqlplugin.RequestCancelInfoMapsRow{requestCancel})
66
>
s.NoError(err)
67
>
rowsAffected, err := result.RowsAffected()
68
>
s.NoError(err)
69
>
s.Equal(1, int(rowsAffected))
70
>
}
71
72
func (s *historyExecutionRequestCancelSuite) TestReplace_Multiple() {