211
}
212
214
>
shardID := rand.Int31()
215
>
namespaceID := primitives.NewUUID()
216
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
217
>
runID := primitives.NewUUID()
218
>
219
>
deleteFilter := sqlplugin.SignalsRequestedSetsAllFilter{
220
>
ShardID: shardID,
221
>
NamespaceID: namespaceID,
222
>
WorkflowID: workflowID,
223
>
RunID: runID,
224
>
}
225
>
result, err := s.store.DeleteAllFromSignalsRequestedSets(newExecutionContext(), deleteFilter)
226
>
s.NoError(err)
227
>
rowsAffected, err := result.RowsAffected()
228
>
s.NoError(err)
229
>
s.Equal(0, int(rowsAffected))
230
>
231
>
selectFilter := sqlplugin.SignalsRequestedSetsAllFilter{
232
>
ShardID: shardID,
233
>
NamespaceID: namespaceID,
234
>
WorkflowID: workflowID,
235
>
RunID: runID,
236
>
}
237
>
rows, err := s.store.SelectAllFromSignalsRequestedSets(newExecutionContext(), selectFilter)
238
>
s.NoError(err)
239
>
s.Equal([]sqlplugin.SignalsRequestedSetsRow(nil), rows)
240
>
}
241
242
func (s *historyExecutionSignalRequestSuite) TestReplaceDeleteSelect_Single() {