597
ephData, ephDataChanged := m.getMergedEphemeralData()
598
if errors.Is(err, errTaskQueueClosed) {
599
>
// If we're closing, return a success with no data, as if the request expired. We shouldn't
user_data_manager.go
600
>
// close due to idleness (because of the MarkAlive above), so we're probably closing due to a
601
>
// change of ownership. The caller will retry and be redirected to the new owner.
602
>
m.logger.Debug("returning empty user data (closing)", tag.Bool("long-poll", req.WaitNewData))
603
>
return &matchingservice.GetTaskQueueUserDataResponse{}, nil
604
} else if err != nil {
605
return nil, err