150
}
151
153
>
shardID := rand.Int31()
154
>
namespaceID := primitives.NewUUID()
155
>
workflowID := shuffle.String(testHistoryExecutionWorkflowID)
156
>
runID := primitives.NewUUID()
157
>
signalID := shuffle.String(testHistoryExecutionSignalID)
158
>
159
>
deleteFilter := sqlplugin.SignalsRequestedSetsFilter{
160
>
ShardID: shardID,
161
>
NamespaceID: namespaceID,
162
>
WorkflowID: workflowID,
163
>
RunID: runID,
164
>
SignalIDs: []string{signalID},
165
>
}
166
>
result, err := s.store.DeleteFromSignalsRequestedSets(newExecutionContext(), deleteFilter)
167
>
s.NoError(err)
168
>
rowsAffected, err := result.RowsAffected()
169
>
s.NoError(err)
170
>
s.Equal(0, int(rowsAffected))
171
>
172
>
selectFilter := sqlplugin.SignalsRequestedSetsAllFilter{
173
>
ShardID: shardID,
174
>
NamespaceID: namespaceID,
175
>
WorkflowID: workflowID,
176
>
RunID: runID,
177
>
}
178
>
rows, err := s.store.SelectAllFromSignalsRequestedSets(newExecutionContext(), selectFilter)
179
>
s.NoError(err)
180
>
s.Equal([]sqlplugin.SignalsRequestedSetsRow(nil), rows)
181
>
}
182
183
func (s *historyExecutionSignalRequestSuite) TestDeleteSelect_Multiple() {