143
}
144
146
>
shardID := rand.Int31()
147
>
namespaceID := primitives.NewUUID()
148
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
149
>
runID := primitives.NewUUID()
150
>
requestID := primitives.NewUUID().String()
151
>
lastWriteVersion := rand.Int63()
152
>
153
>
currentExecution := s.newRandomCurrentExecutionRow(shardID, namespaceID, workflowID, runID, requestID, lastWriteVersion)
154
>
result, err := s.store.InsertIntoCurrentExecutions(newExecutionContext(), ¤tExecution)
155
>
s.NoError(err)
156
>
rowsAffected, err := result.RowsAffected()
157
>
s.NoError(err)
158
>
s.Equal(1, int(rowsAffected))
159
>
160
>
currentExecution = s.newRandomCurrentExecutionRow(shardID, namespaceID, workflowID, runID, primitives.NewUUID().String(), rand.Int63())
161
>
result, err = s.store.UpdateCurrentExecutions(newExecutionContext(), ¤tExecution)
162
>
s.NoError(err)
163
>
rowsAffected, err = result.RowsAffected()
164
>
s.NoError(err)
165
>
s.Equal(1, int(rowsAffected))
166
>
}
167
168
func (s *historyCurrentExecutionSuite) TestUpdate_Fail() {