179
}
180
182
>
shardID := rand.Int31()
183
>
taskID := int64(1)
184
>
185
>
filter := sqlplugin.VisibilityTasksFilter{
186
>
ShardID: shardID,
187
>
TaskID: taskID,
188
>
}
189
>
result, err := s.store.DeleteFromVisibilityTasks(newExecutionContext(), filter)
190
>
s.NoError(err)
191
>
rowsAffected, err := result.RowsAffected()
192
>
s.NoError(err)
193
>
s.Equal(0, int(rowsAffected))
194
>
195
>
rangeFilter := sqlplugin.VisibilityTasksRangeFilter{
196
>
ShardID: shardID,
197
>
InclusiveMinTaskID: taskID,
198
>
ExclusiveMaxTaskID: taskID + 1,
199
>
PageSize: 1,
200
>
}
201
>
rows, err := s.store.RangeSelectFromVisibilityTasks(newExecutionContext(), rangeFilter)
202
>
s.NoError(err)
203
>
for index := range rows {
204
rows[index].ShardID = shardID
205
}
207
}
208