59
}
60
62
>
shardID := rand.Int31()
63
>
namespaceID := primitives.NewUUID()
64
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
65
>
runID := primitives.NewUUID()
66
>
nextEventID := rand.Int63()
67
>
lastWriteVersion := rand.Int63()
68
>
69
>
execution := s.newRandomExecutionRow(shardID, namespaceID, workflowID, runID, nextEventID, lastWriteVersion)
70
>
result, err := s.store.InsertIntoExecutions(newExecutionContext(), &execution)
71
>
s.NoError(err)
72
>
rowsAffected, err := result.RowsAffected()
73
>
s.NoError(err)
74
>
s.Equal(1, int(rowsAffected))
75
>
}
76
77
func (s *historyExecutionSuite) TestInsert_Fail_Duplicate() {