181
}
182
184
>
shardID := rand.Int31()
185
>
namespaceID := primitives.NewUUID()
186
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
187
>
runID := primitives.NewUUID()
188
>
189
>
deleteFilter := sqlplugin.SignalsRequestedSetsFilter{
190
>
ShardID: shardID,
191
>
NamespaceID: namespaceID,
192
>
WorkflowID: workflowID,
193
>
RunID: runID,
194
>
SignalIDs: []string{shuffle.String(testHistoryExecutionSignalID), shuffle.String(testHistoryExecutionSignalID)},
195
>
}
196
>
result, err := s.store.DeleteFromSignalsRequestedSets(newExecutionContext(), deleteFilter)
197
>
s.NoError(err)
198
>
rowsAffected, err := result.RowsAffected()
199
>
s.NoError(err)
200
>
s.Equal(0, int(rowsAffected))
201
>
202
>
selectFilter := sqlplugin.SignalsRequestedSetsAllFilter{
203
>
ShardID: shardID,
204
>
NamespaceID: namespaceID,
205
>
WorkflowID: workflowID,
206
>
RunID: runID,
207
>
}
208
>
rows, err := s.store.SelectAllFromSignalsRequestedSets(newExecutionContext(), selectFilter)
209
>
s.NoError(err)
210
>
s.Equal([]sqlplugin.SignalsRequestedSetsRow(nil), rows)
211
>
}
212
213
func (s *historyExecutionSignalRequestSuite) TestDeleteSelect_All() {