diff --git a/code/api/index-api/src/main/java/nu/marginalia/index/client/IndexClient.java b/code/api/index-api/src/main/java/nu/marginalia/index/client/IndexClient.java
index b500c8c6..9f232cce 100644
--- a/code/api/index-api/src/main/java/nu/marginalia/index/client/IndexClient.java
+++ b/code/api/index-api/src/main/java/nu/marginalia/index/client/IndexClient.java
@@ -8,6 +8,7 @@ import io.reactivex.rxjava3.core.Observable;
 import io.reactivex.rxjava3.schedulers.Schedulers;
 import nu.marginalia.client.AbstractDynamicClient;
 import nu.marginalia.client.Context;
+import nu.marginalia.client.exception.RouteNotConfiguredException;
 import nu.marginalia.index.client.model.query.SearchSpecification;
 import nu.marginalia.index.client.model.results.SearchResultSet;
 import nu.marginalia.model.gson.GsonFactory;
@@ -56,12 +57,15 @@ public class IndexClient extends AbstractDynamicClient {
     @CheckReturnValue
     public SearchResultSet query(Context ctx, List<Integer> nodes, SearchSpecification specs) {
         return Observable.fromIterable(nodes)
-                .concatMap(node -> this
-                        .postGet(ctx, node,"/search/", specs, SearchResultSet.class)
-                        .onErrorReturn(t -> new SearchResultSet()),
-                        nodes.size(),
-                        Schedulers.io()
-                )
+                .flatMap(node -> {
+                    try {
+                        return this
+                                .postGet(ctx, node, "/search/", specs, SearchResultSet.class).onErrorReturn(t -> new SearchResultSet())
+                                .observeOn(Schedulers.io());
+                    } catch (RouteNotConfiguredException ex) {
+                        return Observable.error(ex);
+                    }
+                })
                 .reduce(SearchResultSet::combine)
                 .blockingGet();
     }