183
})
184
switch err.(type) {
186
>
db.rangeID = response.RangeID
187
>
// If we are the draining one, then assume the other has tasks, so we can migrate
188
>
// backwards safely.
189
>
db.otherHasTasks = response.TaskQueueInfo.OtherHasTasks || db.isDraining
190
>
db.subqueues = db.ensureDefaultSubqueuesLocked(
191
>
response.TaskQueueInfo.Subqueues,
192
>
response.TaskQueueInfo.AckLevel,
193
>
response.TaskQueueInfo.ApproximateBacklogCount,
194
>
)
195
>
db.scaleState = response.TaskQueueInfo.PartitionScaleState
196
>
err := db.updateTaskQueueLocked(ctx, true)
197
>
if err != nil {
198
db.rangeID = 0
199
return err