Merge pull request #27 from pamelafox/devuifix

Fix structured outputs for devui

Author: pamelafox

examples/spanish/workflow_aggregator_voting.py

@@ -87,7 +87,7 @@ async def tally(
         """Cuenta votos de clasificadores y devuelve la categoría ganadora."""
         votes: list[tuple[str, str]] = []
         for result in results:
-            classification: Classification = result.agent_response.value
+            classification = Classification.model_validate_json(result.agent_response.text)
             votes.append((result.executor_id, classification.category.value))
 
         labels = [label for _, label in votes]

examples/spanish/workflow_conditional_state.py

@@ -62,7 +62,7 @@ def parse_review_decision(message: Any) -> ReviewDecision | None:
     if not isinstance(message, AgentExecutorResponse):
         return None
 
-    return message.agent_response.value
+    return ReviewDecision.model_validate_json(message.agent_response.text)
 
 
 # Funciones de condición — reciben el mensaje del ejecutor anterior.

examples/spanish/workflow_conditional_state_isolated.py

@@ -67,7 +67,7 @@ def parse_review_decision(message: Any) -> ReviewDecision | None:
     if not isinstance(message, AgentExecutorResponse):
         return None
 
-    return message.agent_response.value
+    return ReviewDecision.model_validate_json(message.agent_response.text)
 
 
 # Funciones de condición — reciben el mensaje del ejecutor anterior.

examples/spanish/workflow_conditional_structured.py

@@ -66,7 +66,7 @@ def parse_review_decision(message: Any) -> ReviewDecision | None:
     if not isinstance(message, AgentExecutorResponse):
         return None
 
-    return message.agent_response.value
+    return ReviewDecision.model_validate_json(message.agent_response.text)
 
 
 def is_approved(message: Any) -> bool:

examples/spanish/workflow_converge.py

@@ -60,7 +60,7 @@ def parse_review_result(message: Any) -> ReviewResult | None:
     if not isinstance(message, AgentExecutorResponse):
         return None
 
-    return message.agent_response.value
+    return ReviewResult.model_validate_json(message.agent_response.text)
 
 
 def is_approved(message: Any) -> bool:

examples/spanish/workflow_switch_case.py

@@ -87,7 +87,7 @@ class ClassifyResult(BaseModel):
 @executor(id="extract_category")
 async def extract_category(response: AgentExecutorResponse, ctx: WorkflowContext[ClassifyResult]) -> None:
     """Analiza la salida JSON estructurada del clasificador y la envía aguas abajo."""
-    result: ClassifyResult = response.agent_response.value
+    result = ClassifyResult.model_validate_json(response.agent_response.text)
     print(f"→ Clasificado como: {result.category} — {result.reasoning}")
     await ctx.send_message(result)
 

examples/workflow_aggregator_voting.py

@@ -85,7 +85,7 @@ async def tally(
         """Count classifier votes and yield the winning category."""
         votes: list[tuple[str, str]] = []
         for result in results:
-            classification: Classification = result.agent_response.value
+            classification = Classification.model_validate_json(result.agent_response.text)
             votes.append((result.executor_id, classification.category.value))
 
         labels = [label for _, label in votes]

examples/workflow_conditional_state.py

@@ -62,7 +62,7 @@ def parse_review_decision(message: Any) -> ReviewDecision | None:
     if not isinstance(message, AgentExecutorResponse):
         return None
 
-    return message.agent_response.value
+    return ReviewDecision.model_validate_json(message.agent_response.text)
 
 
 # Condition functions — receive the message from the previous executor.
@@ -149,6 +149,7 @@ async def publisher(response: AgentExecutorResponse, ctx: WorkflowContext[Never,
     .build()
 )
 
+
 async def main():
     prompt = "Write a LinkedIn post predicting the 5 jobs AI agents will replace by December 2026."
     print(f"Prompt: {prompt}\n")

examples/workflow_conditional_state_isolated.py

@@ -66,7 +66,7 @@ def parse_review_decision(message: Any) -> ReviewDecision | None:
     if not isinstance(message, AgentExecutorResponse):
         return None
 
-    return message.agent_response.value
+    return ReviewDecision.model_validate_json(message.agent_response.text)
 
 
 # Condition functions — receive the message from the previous executor.

examples/workflow_conditional_structured.py

@@ -66,7 +66,7 @@ def parse_review_decision(message: Any) -> ReviewDecision | None:
     if not isinstance(message, AgentExecutorResponse):
         return None
 
-    return message.agent_response.value
+    return ReviewDecision.model_validate_json(message.agent_response.text)
 
 
 def is_approved(message: Any) -> bool:
@@ -142,6 +142,7 @@ async def main():
     print(f"Prompt: {prompt}\n")
     events = await workflow.run(prompt)
     for output in events.get_outputs():
+        print('Output:')
         print(output)
 
     if async_credential: