166
}
167
169
>
shardID := rand.Int31()
170
>
namespaceID := primitives.NewUUID()
171
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
172
>
runID := primitives.NewUUID()
173
>
requestID := primitives.NewUUID().String()
174
>
lastWriteVersion := rand.Int63()
175
>
176
>
currentExecution := s.newRandomCurrentExecutionRow(shardID, namespaceID, workflowID, runID, requestID, lastWriteVersion)
177
>
result, err := s.store.UpdateCurrentExecutions(newExecutionContext(), ¤tExecution)
178
>
s.NoError(err)
179
>
rowsAffected, err := result.RowsAffected()
180
>
s.NoError(err)
181
>
s.Equal(0, int(rowsAffected))
182
>
}
183
184
func (s *historyCurrentExecutionSuite) TestInsertUpdateSelect() {