Mirror/MarginaliaSearch
1
0
Fork 0
mirror of https://github.com/MarginaliaSearch/MarginaliaSearch.git synced 2025-02-23 13:09:00 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

(assistant) Don't attempt to respond to similarity and linkedness queries before the data is ready

Browse Source 
This will reduce the number of exceptions in the assistant logs quite significantly.
This commit is contained in:
Viktor Lofgren 2024-09-27 14:08:08 +02:00
parent 31f30069a4
commit c91435e314
1 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
code/functions/domain-info/java/nu/marginalia/functions/domains/DomainInfoGrpcService.java
View File

@ -32,11 +32,15 @@ public class DomainInfoGrpcService
@Override
public void getSimilarDomains(RpcDomainLinksRequest request,
StreamObserver<RpcSimilarDomains> responseObserver) {
var ret = similarDomainsService.getSimilarDomains(request.getDomainId(), request.getCount());
var responseBuilder = RpcSimilarDomains
.newBuilder()
.addAllDomains(ret);
var responseBuilder = RpcSimilarDomains.newBuilder();
if (similarDomainsService.isReady()) {
var ret = similarDomainsService.getSimilarDomains(request.getDomainId(), request.getCount());
responseBuilder.addAllDomains(ret);
}
responseObserver.onNext(responseBuilder.build());
responseObserver.onCompleted();
@ -44,11 +48,12 @@ public class DomainInfoGrpcService
@Override
public void getLinkingDomains(RpcDomainLinksRequest request, StreamObserver<RpcSimilarDomains> responseObserver) {
var ret = similarDomainsService.getLinkingDomains(request.getDomainId(), request.getCount());
var responseBuilder = RpcSimilarDomains.newBuilder();
var responseBuilder = RpcSimilarDomains
.newBuilder()
.addAllDomains(ret);
if (similarDomainsService.isReady()) {
var ret = similarDomainsService.getLinkingDomains(request.getDomainId(), request.getCount());
responseBuilder.addAllDomains(ret);
}
responseObserver.onNext(responseBuilder.build());
responseObserver.onCompleted();