207
}
208
210
>
shardID := rand.Int31()
211
>
minTaskID := int64(1)
212
>
maxTaskID := int64(101)
213
>
214
>
filter := sqlplugin.VisibilityTasksRangeFilter{
215
>
ShardID: shardID,
216
>
InclusiveMinTaskID: minTaskID,
217
>
ExclusiveMaxTaskID: maxTaskID,
218
>
PageSize: int(maxTaskID - minTaskID),
219
>
}
220
>
result, err := s.store.RangeDeleteFromVisibilityTasks(newExecutionContext(), filter)
221
>
s.NoError(err)
222
>
rowsAffected, err := result.RowsAffected()
223
>
s.NoError(err)
224
>
s.Equal(0, int(rowsAffected))
225
>
226
>
rows, err := s.store.RangeSelectFromVisibilityTasks(newExecutionContext(), filter)
227
>
s.NoError(err)
228
>
for index := range rows {
229
rows[index].ShardID = shardID
230
}
232
}
233