116
}
117
119
>
shardID := rand.Int31()
120
>
namespaceID := primitives.NewUUID()
121
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
122
>
runID := primitives.NewUUID()
123
>
requestID := primitives.NewUUID().String()
124
>
lastWriteVersion := rand.Int63()
125
>
126
>
currentExecution := s.newRandomCurrentExecutionRow(shardID, namespaceID, workflowID, runID, requestID, lastWriteVersion)
127
>
result, err := s.store.InsertIntoCurrentExecutions(newExecutionContext(), ¤tExecution)
128
>
s.NoError(err)
129
>
rowsAffected, err := result.RowsAffected()
130
>
s.NoError(err)
131
>
s.Equal(1, int(rowsAffected))
132
>
133
>
filter := sqlplugin.CurrentExecutionsFilter{
134
>
ShardID: shardID,
135
>
NamespaceID: namespaceID,
136
>
WorkflowID: workflowID,
137
>
RunID: nil,
138
>
ArchetypeID: s.archetypeID,
139
>
}
140
>
row, err := s.store.SelectFromCurrentExecutions(newExecutionContext(), filter)
141
>
s.NoError(err)
142
>
s.Equal(¤tExecution, row)
143
>
}
144
145
func (s *historyCurrentExecutionSuite) TestInsertUpdate_Success() {