Responsive Gui - partially Workflow #61
|
|
@ -228,9 +228,9 @@ def load_question_catalog(db_connection) -> Dict[str, Dict]:
|
|||
|
||||
catalog = {}
|
||||
for row in rows:
|
||||
catalog[row[0]] = {
|
||||
"answer_spectrum": row[1], # JSONB already parsed by psycopg2
|
||||
"normalization_rules": row[2] # JSONB or None
|
||||
catalog[row['question_type']] = {
|
||||
"answer_spectrum": row['answer_spectrum'], # JSONB already parsed by psycopg2
|
||||
"normalization_rules": row['normalization_rules'] # JSONB or None
|
||||
}
|
||||
|
||||
logger.info(f"Loaded question catalog: {len(catalog)} types")
|
||||
|
|
|
|||
|
|
@ -80,7 +80,7 @@ async def execute_workflow(
|
|||
if not row:
|
||||
raise ValueError(f"Workflow not found: {workflow_id}")
|
||||
|
||||
graph_json = row[0]
|
||||
graph_json = row['graph']
|
||||
|
||||
# 2. Parse Graph
|
||||
graph = parse_workflow_graph(graph_json)
|
||||
|
|
@ -309,7 +309,7 @@ async def load_prompt_template(prompt_slug: str, context: Dict[str, Any]) -> str
|
|||
if not row:
|
||||
raise ValueError(f"Prompt not found: {prompt_slug}")
|
||||
|
||||
template = row[0]
|
||||
template = row['template']
|
||||
|
||||
# Resolve Placeholders
|
||||
profile_id = context.get("profile_id")
|
||||
|
|
|
|||
Loading…
Reference in New Issue
Block a user