96
}
97
99
>
shardID := rand.Int31()
100
>
namespaceID := primitives.NewUUID()
101
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
102
>
runID := primitives.NewUUID()
103
>
requestID := primitives.NewUUID().String()
104
>
lastWriteVersion := rand.Int63()
105
>
106
>
currentExecution := s.newRandomCurrentExecutionRow(shardID, namespaceID, workflowID, runID, requestID, lastWriteVersion)
107
>
result, err := s.store.InsertIntoCurrentExecutions(newExecutionContext(), ¤tExecution)
108
>
s.NoError(err)
109
>
rowsAffected, err := result.RowsAffected()
110
>
s.NoError(err)
111
>
s.Equal(1, int(rowsAffected))
112
>
113
>
currentExecution = s.newRandomCurrentExecutionRow(shardID, namespaceID, workflowID, runID, requestID, lastWriteVersion)
114
>
_, err = s.store.InsertIntoCurrentExecutions(newExecutionContext(), ¤tExecution)
115
>
s.Error(err) // TODO persistence layer should do proper error translation
116
>
}
117
118
func (s *historyCurrentExecutionSuite) TestInsertSelect() {