80
}
81
83
>
shardID := rand.Int31()
84
>
namespaceID := primitives.NewUUID()
85
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
86
>
runID := primitives.NewUUID()
87
>
requestID := primitives.NewUUID().String()
88
>
lastWriteVersion := rand.Int63()
89
>
90
>
currentExecution := s.newRandomCurrentExecutionRow(shardID, namespaceID, workflowID, runID, requestID, lastWriteVersion)
91
>
result, err := s.store.InsertIntoCurrentExecutions(newExecutionContext(), ¤tExecution)
92
>
s.NoError(err)
93
>
rowsAffected, err := result.RowsAffected()
94
>
s.NoError(err)
95
>
s.Equal(1, int(rowsAffected))
96
>
}
97
98
func (s *historyCurrentExecutionSuite) TestInsert_Fail_Duplicate() {