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

(actor) Improve error messages for convert-and-load

Browse Source 
Some copy-and-paste errors had snuck in and every index construction error was reported as "repartitioned failed"; updated with more useful messages.
This commit is contained in:
Viktor Lofgren 2024-07-08 19:19:30 +02:00
parent d90bd340bb
commit 12a2ab93db
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
code/execution/java/nu/marginalia/actor/task/ConvertAndLoadActor.java
View File

@ -146,7 +146,7 @@ public class ConvertAndLoadActor extends RecordActorPrototype {
var rsp = processWatcher.waitResponse(mqIndexConstructorOutbox, ProcessService.ProcessId.INDEX_CONSTRUCTOR, id); var rsp = processWatcher.waitResponse(mqIndexConstructorOutbox, ProcessService.ProcessId.INDEX_CONSTRUCTOR, id);
if (rsp.state() != MqMessageState.OK) if (rsp.state() != MqMessageState.OK)
yield new Error("Repartition failed"); yield new Error("Forward index construction failed");
else else
yield new ReindexFull(); yield new ReindexFull();
} }
@ -155,7 +155,7 @@ public class ConvertAndLoadActor extends RecordActorPrototype {
var rsp = processWatcher.waitResponse(mqIndexConstructorOutbox, ProcessService.ProcessId.INDEX_CONSTRUCTOR, id); var rsp = processWatcher.waitResponse(mqIndexConstructorOutbox, ProcessService.ProcessId.INDEX_CONSTRUCTOR, id);
if (rsp.state() != MqMessageState.OK) if (rsp.state() != MqMessageState.OK)
yield new Error("Repartition failed"); yield new Error("Full index construction failed");
else else
yield new ReindexPrio(); yield new ReindexPrio();
} }
@ -164,7 +164,7 @@ public class ConvertAndLoadActor extends RecordActorPrototype {
var rsp = processWatcher.waitResponse(mqIndexConstructorOutbox, ProcessService.ProcessId.INDEX_CONSTRUCTOR, id); var rsp = processWatcher.waitResponse(mqIndexConstructorOutbox, ProcessService.ProcessId.INDEX_CONSTRUCTOR, id);
if (rsp.state() != MqMessageState.OK) if (rsp.state() != MqMessageState.OK)
yield new Error("Repartition failed"); yield new Error("Prio index construction failed");
else else
yield new SwitchIndex(); yield new SwitchIndex();
} }