Skip to content

Commit 495e32a

Browse files
authored
Merge pull request #154 from rostilos/1.5.3-rc
feat: Enhance RAG incremental update notifications with detailed status messages
2 parents 6239553 + 1a4247e commit 495e32a

1 file changed

Lines changed: 8 additions & 0 deletions

File tree

java-ecosystem/libs/analysis-engine/src/main/java/org/rostilos/codecrow/analysisengine/processor/analysis/BranchAnalysisProcessor.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -634,17 +634,23 @@ private void performIncrementalRagUpdate(BranchProcessRequest request, Project p
634634
Consumer<Map<String, Object>> consumer) {
635635
if (ragOperationsService == null) {
636636
log.info("Skipping RAG incremental update - RagOperationsService not available");
637+
EventNotificationEmitter.emitStatus(consumer, "rag_skipped",
638+
"RAG module not deployed — skipping incremental update");
637639
return;
638640
}
639641
try {
640642
if (!ragOperationsService.isRagEnabled(project)) {
641643
log.info("Skipping RAG incremental update - RAG not enabled for project={}",
642644
project.getId());
645+
EventNotificationEmitter.emitStatus(consumer, "rag_skipped",
646+
"RAG not enabled for this project — skipping incremental update");
643647
return;
644648
}
645649
if (!ragOperationsService.isRagIndexReady(project)) {
646650
log.info("Skipping RAG incremental update - RAG index not yet ready for project={}",
647651
project.getId());
652+
EventNotificationEmitter.emitStatus(consumer, "rag_skipped",
653+
"RAG index not yet ready (initial indexing may still be in progress) — skipping incremental update");
648654
return;
649655
}
650656

@@ -675,6 +681,8 @@ private void performIncrementalRagUpdate(BranchProcessRequest request, Project p
675681

676682
log.info("RAG update completed for project={}, branch={}, commit={}",
677683
project.getId(), targetBranch, request.getCommitHash());
684+
EventNotificationEmitter.emitStatus(consumer, "rag_update_complete",
685+
"RAG index updated successfully for branch: " + targetBranch);
678686
} catch (Exception e) {
679687
log.warn("RAG incremental update failed (non-critical): {}", e.getMessage());
680688
EventNotificationEmitter.emitStatus(consumer, "rag_update_failed",

0 commit comments

Comments
 (0)