diff --git a/responsemanager/server.go b/responsemanager/server.go index 68a33934..f5571691 100644 --- a/responsemanager/server.go +++ b/responsemanager/server.go @@ -140,7 +140,7 @@ func (rm *ResponseManager) abortRequest(ctx context.Context, requestID graphsync if ok { rm.responseQueue.Remove(requestID, response.peer) } - if !ok || response.state == graphsync.CompletingSend { + if !ok || (response.state == graphsync.CompletingSend && !errors.Is(err, queryexecutor.ErrNetworkError)) { return graphsync.RequestNotFoundErr{} }