Release v3.9.33

Author: MervinPraison

docker/Dockerfile.chat

@@ -16,7 +16,7 @@ RUN mkdir -p /root/.praison
 # Install Python packages (using latest versions)
 RUN pip install --no-cache-dir \
     praisonai_tools \
-    "praisonai>=3.9.32" \
+    "praisonai>=3.9.33" \
     "praisonai[chat]" \
     "embedchain[github,youtube]"
 

docker/Dockerfile.dev

@@ -20,7 +20,7 @@ RUN mkdir -p /root/.praison
 # Install Python packages (using latest versions)
 RUN pip install --no-cache-dir \
     praisonai_tools \
-    "praisonai>=3.9.32" \
+    "praisonai>=3.9.33" \
     "praisonai[ui]" \
     "praisonai[chat]" \
     "praisonai[realtime]" \

docker/Dockerfile.ui

@@ -16,7 +16,7 @@ RUN mkdir -p /root/.praison
 # Install Python packages (using latest versions)
 RUN pip install --no-cache-dir \
     praisonai_tools \
-    "praisonai>=3.9.32" \
+    "praisonai>=3.9.33" \
     "praisonai[ui]" \
     "praisonai[crewai]"
 

src/praisonai-agents/praisonaiagents/workflows/workflows.py

@@ -134,6 +134,7 @@ class Loop:
     var_name: str = "item"  # Variable name for current item
     parallel: bool = False  # Execute iterations in parallel
     max_workers: Optional[int] = None  # Max parallel workers (None = unlimited)
+    output_variable: Optional[str] = None  # Store loop results in this variable name
 
     def __init__(
         self, 
@@ -143,7 +144,8 @@ def __init__(
         from_file: Optional[str] = None,
         var_name: str = "item",
         parallel: bool = False,
-        max_workers: Optional[int] = None
+        max_workers: Optional[int] = None,
+        output_variable: Optional[str] = None
     ):
         self.step = step
         self.over = over
@@ -152,6 +154,7 @@ def __init__(
         self.var_name = var_name
         self.parallel = parallel
         self.max_workers = max_workers
+        self.output_variable = output_variable
 
 
 @dataclass
@@ -194,7 +197,8 @@ def parallel(steps: List) -> Parallel:
 
 def loop(step: Any, over: Optional[str] = None, from_csv: Optional[str] = None, 
          from_file: Optional[str] = None, var_name: str = "item",
-         parallel: bool = False, max_workers: Optional[int] = None) -> Loop:
+         parallel: bool = False, max_workers: Optional[int] = None,
+         output_variable: Optional[str] = None) -> Loop:
     """Loop over items executing step for each.
     
     Args:
@@ -205,12 +209,14 @@ def loop(step: Any, over: Optional[str] = None, from_csv: Optional[str] = None,
         var_name: Variable name for current item (default: "item")
         parallel: If True, execute iterations in parallel (default: False)
         max_workers: Max parallel workers when parallel=True (default: None = unlimited)
+        output_variable: Variable name to store all loop outputs (default: None = "loop_outputs")
     
     Returns:
         Loop object configured for iteration
     """
     return Loop(step=step, over=over, from_csv=from_csv, from_file=from_file, 
-                var_name=var_name, parallel=parallel, max_workers=max_workers)
+                var_name=var_name, parallel=parallel, max_workers=max_workers,
+                output_variable=output_variable)
 
 
 def repeat(step: Any, until: Optional[Callable[[WorkflowContext], bool]] = None,
@@ -1829,10 +1835,16 @@ def execute_item(idx_item_tuple):
                 results.append({"step": f"{step_result['step']}_{idx}", "output": step_result["output"]})
                 outputs.append(step_result["output"])
                 previous_output = step_result["output"]
-        
-        all_variables["loop_outputs"] = outputs
+        # Store outputs in user-specified variable or default to loop_outputs
+        output_var_name = loop_step.output_variable or "loop_outputs"
+        all_variables[output_var_name] = outputs
+        all_variables["loop_outputs"] = outputs  # Also keep for backward compatibility
         combined_output = "\n".join(str(o) for o in outputs) if outputs else ""
 
+        # Debug logging for output_variable
+        if verbose:
+            print(f"📦 Loop stored {len(outputs)} results in variable: '{output_var_name}'")
+        
         return {"steps": results, "output": combined_output, "variables": all_variables}
 
     def _parse_list_from_string(self, text: str) -> List[Any]:

src/praisonai-agents/praisonaiagents/workflows/yaml_parser.py

@@ -790,14 +790,18 @@ def _parse_loop_step(self, step_data: Dict):
         if agent_or_step is None:
             raise ValueError("Loop step requires an agent or include")
 
+        # Extract output_variable from step level (where user specifies it in YAML)
+        output_variable = step_data.get('output_variable')
+        
         return loop(
             agent_or_step, 
             over=over, 
             from_csv=from_csv, 
             from_file=from_file,
             var_name=var_name,
             parallel=parallel_flag, 
-            max_workers=max_workers
+            max_workers=max_workers,
+            output_variable=output_variable
         )
 
     def _parse_repeat_step(self, step_data: Dict) -> Dict:

src/praisonai-agents/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "praisonaiagents"
-version = "0.12.16"
+version = "0.12.17"
 description = "Praison AI agents for completing complex tasks with Self Reflection Agents"
 readme = "README.md"
 requires-python = ">=3.10"

src/praisonai-agents/uv.lock

@@ -3,8 +3,8 @@ class Praisonai < Formula
 
     desc "AI tools for various AI applications"
     homepage "https://github.com/MervinPraison/PraisonAI"
-    url "https://github.com/MervinPraison/PraisonAI/archive/refs/tags/v3.9.32.tar.gz"
-    sha256 `curl -sL https://github.com/MervinPraison/PraisonAI/archive/refs/tags/v3.9.32.tar.gz | shasum -a 256`.split.first
+    url "https://github.com/MervinPraison/PraisonAI/archive/refs/tags/v3.9.33.tar.gz"
+    sha256 `curl -sL https://github.com/MervinPraison/PraisonAI/archive/refs/tags/v3.9.33.tar.gz | shasum -a 256`.split.first
     license "MIT"
 
     depends_on "python@3.11"

src/praisonai/praisonai.rb

@@ -57,7 +57,7 @@ def create_dockerfile(self):
             file.write("FROM python:3.11-slim\n")
             file.write("WORKDIR /app\n")
             file.write("COPY . .\n")
-            file.write("RUN pip install flask praisonai==3.9.32 gunicorn markdown\n")
+            file.write("RUN pip install flask praisonai==3.9.33 gunicorn markdown\n")
             file.write("EXPOSE 8080\n")
             file.write('CMD ["gunicorn", "-b", "0.0.0.0:8080", "api:app"]\n')
 

src/praisonai/praisonai/deploy.py

@@ -1 +1 @@
-__version__ = "3.9.32"
+__version__ = "3.9.33"