From 990b259536e9190654699bd8e60dc38d66282346 Mon Sep 17 00:00:00 2001 From: Esity Date: Mon, 18 May 2026 23:39:01 -0500 Subject: [PATCH] Add source_agent/source_channel to Apollo ingest calls Identity is now enforced at the lex-apollo layer via Legion::Identity::Process. Add source_agent and source_channel to ingest_to_apollo payload for provenance tracking. --- lib/legion/extensions/knowledge/runners/ingest.rb | 14 ++++++++------ lib/legion/extensions/knowledge/version.rb | 2 +- 2 files changed, 9 insertions(+), 7 deletions(-) diff --git a/lib/legion/extensions/knowledge/runners/ingest.rb b/lib/legion/extensions/knowledge/runners/ingest.rb index 9c98d68..49d7880 100644 --- a/lib/legion/extensions/knowledge/runners/ingest.rb +++ b/lib/legion/extensions/knowledge/runners/ingest.rb @@ -320,12 +320,14 @@ def ingest_to_apollo(chunk, embedding) token_count: chunk[:token_count] } payload = { - content: chunk[:content], - content_type: 'document_chunk', - content_hash: chunk[:content_hash], - tags: [chunk[:source_file], chunk[:heading], 'document_chunk'].compact.uniq, - context: context, - metadata: context + content: chunk[:content], + content_type: 'document_chunk', + content_hash: chunk[:content_hash], + tags: [chunk[:source_file], chunk[:heading], 'document_chunk'].compact.uniq, + source_agent: 'lex-knowledge', + source_channel: 'corpus_ingest', + context: context, + metadata: context } payload[:embedding] = embedding if embedding diff --git a/lib/legion/extensions/knowledge/version.rb b/lib/legion/extensions/knowledge/version.rb index e38c2de..563e322 100644 --- a/lib/legion/extensions/knowledge/version.rb +++ b/lib/legion/extensions/knowledge/version.rb @@ -3,7 +3,7 @@ module Legion module Extensions module Knowledge - VERSION = '0.6.15' + VERSION = '0.6.16' end end end