121
}
122
124
>
shardID := rand.Int31()
125
>
namespaceID := primitives.NewUUID()
126
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
127
>
runID := primitives.NewUUID()
128
>
nextEventID := rand.Int63()
129
>
lastWriteVersion := rand.Int63()
130
>
131
>
execution := s.newRandomExecutionRow(shardID, namespaceID, workflowID, runID, nextEventID, lastWriteVersion)
132
>
result, err := s.store.InsertIntoExecutions(newExecutionContext(), &execution)
133
>
s.NoError(err)
134
>
rowsAffected, err := result.RowsAffected()
135
>
s.NoError(err)
136
>
s.Equal(1, int(rowsAffected))
137
>
138
>
execution = s.newRandomExecutionRow(shardID, namespaceID, workflowID, runID, rand.Int63(), rand.Int63())
139
>
result, err = s.store.UpdateExecutions(newExecutionContext(), &execution)
140
>
s.NoError(err)
141
>
rowsAffected, err = result.RowsAffected()
142
>
s.NoError(err)
143
>
s.Equal(1, int(rowsAffected))
144
>
}
145
146
func (s *historyExecutionSuite) TestUpdate_Fail() {