From ef8cf719f2c6497cd26694642b2b2e5ee6b2286e Mon Sep 17 00:00:00 2001 From: Lars Date: Tue, 30 Dec 2025 09:11:55 +0100 Subject: [PATCH] Update ingestion processor to version 2.13.12, synchronizing profile resolution with registry defaults. Refactor profile retrieval logic to utilize the profile determined in make_note_payload, ensuring consistency in chunk configuration. --- app/core/ingestion/ingestion_processor.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/app/core/ingestion/ingestion_processor.py b/app/core/ingestion/ingestion_processor.py index e868401..22ae909 100644 --- a/app/core/ingestion/ingestion_processor.py +++ b/app/core/ingestion/ingestion_processor.py @@ -4,8 +4,8 @@ DESCRIPTION: Der zentrale IngestionService (Orchestrator). WP-14: Modularisierung der Datenbank-Ebene (app.core.database). WP-15b: Two-Pass Workflow mit globalem Kontext-Cache. WP-20/22: Cloud-Resilienz und Content-Lifecycle integriert. - AUDIT v2.13.11: Synchronisierung mit Atomic-Chunking v3.9.9. -VERSION: 2.13.11 + AUDIT v2.13.12: Synchronisierung der Profil-Auflösung mit Registry-Defaults. +VERSION: 2.13.12 STATUS: Active """ import logging @@ -155,12 +155,15 @@ class IngestionService: edge_registry.ensure_latest() # Profil-Auflösung via Registry - profile = fm.get("chunk_profile") or fm.get("chunking_profile") or "sliding_standard" + # FIX: Wir nutzen das Profil, das bereits in make_note_payload unter + # Berücksichtigung der types.yaml (Registry) ermittelt wurde. + profile = note_pl.get("chunk_profile", "sliding_standard") + chunk_cfg = get_chunk_config_by_profile(self.registry, profile, note_type) enable_smart = chunk_cfg.get("enable_smart_edge_allocation", False) # WP-15b: Chunker-Aufruf bereitet den Candidate-Pool pro Chunk vor. - # assemble_chunks (v3.3.4) führt intern auch die Propagierung durch. + # assemble_chunks führt intern auch die Propagierung durch. chunks = await assemble_chunks(note_id, body_text, note_type, config=chunk_cfg) # Semantische Kanten-Validierung (Smart Edge Allocation)