Lars/mitai-jinkendo
1
0
Fork 0
Code Issues 33 Pull Requests Actions Packages Projects Releases 5 Wiki Activity

Universal CSV Importer #70

Merged
Lars merged 54 commits from develop into main 2026-04-11 07:06:47 +02:00
Conversation 0 Commits 54 Files Changed 187 +5 -11
1 changed files with 5 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 73963e7140 - Show all commits

16
backend/workflow_executor.py
View File

@ -28,7 +28,7 @@ from question_augmenter import (
parse_question_augmentations_from_jsonb parse_question_augmentations_from_jsonb
) )
from result_container_parser import parse_result_container from result_container_parser import parse_result_container
from normalization_engine import normalize_all_signals, normalize_signal_value, load_question_catalog from normalization_engine import normalize_all_signals, normalize_decision_signal, load_question_catalog
from logic_evaluator import evaluate_logic_expression, resolve_signal_reference from logic_evaluator import evaluate_logic_expression, resolve_signal_reference
from join_evaluator import evaluate_join_node as evaluate_join_node_core from join_evaluator import evaluate_join_node as evaluate_join_node_core
from db import get_db, get_cursor from db import get_db, get_cursor
@ -334,21 +334,15 @@ async def execute_node(
type_catalog_entry = catalog.get(q_config['type'], {}) type_catalog_entry = catalog.get(q_config['type'], {})
# Normalize with question-specific spectrum # Normalize with question-specific spectrum
normalized = normalize_signal_value( normalized_signal = normalize_decision_signal(
question_type=signal_id, # Use ID as question_type
raw_value=signal_value, raw_value=signal_value,
answer_spectrum=q_config['answer_spectrum'], answer_spectrum=q_config['answer_spectrum'],
normalization_rules=type_catalog_entry.get('normalization_rules') normalization_rules=type_catalog_entry.get('normalization_rules')
) )
normalized_signals.append(NormalizedSignal( normalized_signals.append(normalized_signal)
question_type=signal_id, # Store ID as question_type (for template access) logger.debug(f"Node {node.id}: Normalized signal '{signal_id}' = '{signal_value}' → '{normalized_signal.normalized_value}' (status: {normalized_signal.status})")
raw_value=signal_value,
normalized_value=normalized.get('normalized_value'),
status=normalized.get('status'),
confidence=normalized.get('confidence'),
metadata=normalized.get('metadata')
))
logger.debug(f"Node {node.id}: Normalized signal '{signal_id}' = '{signal_value}' → '{normalized.get('normalized_value')}'")
logger.info(f"Node {node.id}: Normalized {len(normalized_signals)} signals") logger.info(f"Node {node.id}: Normalized {len(normalized_signals)} signals")