249
}
250
252
>
shardID := rand.Int31()
253
>
namespaceID := primitives.NewUUID()
254
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
255
>
runID := primitives.NewUUID()
256
>
requestID := primitives.NewUUID().String()
257
>
lastWriteVersion := rand.Int63()
258
>
259
>
currentExecution := s.newRandomCurrentExecutionRow(shardID, namespaceID, workflowID, runID, requestID, lastWriteVersion)
260
>
result, err := s.store.InsertIntoCurrentExecutions(newExecutionContext(), ¤tExecution)
261
>
s.NoError(err)
262
>
rowsAffected, err := result.RowsAffected()
263
>
s.NoError(err)
264
>
s.Equal(1, int(rowsAffected))
265
>
266
>
filter := sqlplugin.CurrentExecutionsFilter{
267
>
ShardID: shardID,
268
>
NamespaceID: namespaceID,
269
>
WorkflowID: workflowID,
270
>
RunID: primitives.NewUUID(),
271
>
ArchetypeID: s.archetypeID,
272
>
}
273
>
result, err = s.store.DeleteFromCurrentExecutions(newExecutionContext(), filter)
274
>
s.NoError(err)
275
>
rowsAffected, err = result.RowsAffected()
276
>
s.NoError(err)
277
>
s.Equal(0, int(rowsAffected))
278
>
279
>
filter.RunID = nil
280
>
row, err := s.store.SelectFromCurrentExecutions(newExecutionContext(), filter)
281
>
s.NoError(err)
282
>
s.Equal(¤tExecution, row)
283
>
}
284
285
func (s *historyCurrentExecutionSuite) TestLock() {