fix: correct MCP SSE launch, shebang ordering, and E2E helper scripts

- execution_mixin: replace non-existent FastMCP.create_app() with the repo's working low-level SSE transport pattern (connect_sse + handle_post_message), matching mcp/mcp_server.py; normalize base_path leading slash. Fixes AttributeError at MCP server startup. - examples (36 files): move '# praisonai: skip=true' below the shebang so direct execution still works; directive stays within the runner's first-30-lines scan. - failover_example: display real 'last_error' instead of unmodeled 'failure_count' (which always printed 0). - scripts/apply_e2e_batch3_*.py: make skip insertion shebang-aware, wire the previously-uncalled fix_mcp_env_examples(), and make the E2E report path a CLI argument (defaulting to the audit path). Co-authored-by: Mervin Praison <[email protected]>
chore: remove committed example run artifacts and ignore them
2026-11-08 17:31:00 -10:00 · 2026-07-23 12:10:41 +00:00 · 2026-07-23 11:38:54 +00:00 · 2026-07-23 17:04:42 +05:30 · 2026-07-22 17:50:43 +00:00 · 2026-07-22 17:13:56 +00:00
273 changed files with 5204 additions and 377 deletions
@@ -49,13 +49,13 @@ jobs:
            // --- Label triage ---
            const labels = [];

-            // Kind labels
+            // Kind labels (bug before "how to" — bug reports often include "## How to fix")
            if (content.includes('feature request') || content.includes('[feature')) {
              labels.push('enhancement');
-            } else if (title.includes('[question]') || content.includes('how do i') || content.includes('how to')) {
-              labels.push('question');
-            } else if (content.includes('bug') || content.includes('error') || content.includes('crash') || content.includes('traceback')) {
+            } else if (!title.includes('[question]') && (content.includes('bug') || content.includes('error') || content.includes('crash') || content.includes('traceback'))) {
              labels.push('bug');
+            } else if (title.includes('[question]') || content.includes('how do i') || (content.includes('how to') && !content.includes('how to fix'))) {
+              labels.push('question');
            } else if (content.includes('question')) {
              labels.push('question');
            }
@@ -108,7 +108,10 @@ jobs:
            // --- Auto-trigger Claude for owner issues and actionable external bug/enhancement reports ---
            const titleLower = (issue.title || '').toLowerCase();
            const hasActionableTitle = /^(\[[^\]]+\]|bug:|fix[:(]|feat:|ux:|enhancement:)/i.test(titleLower);
-            const autoClaude = isOwner || (hasActionableTitle && (labels.includes('bug') || labels.includes('enhancement')) && !labels.includes('question'));
+            const autoClaude = isOwner || (hasActionableTitle && (
+              labels.includes('bug') ||
+              (labels.includes('enhancement') && !labels.includes('question'))
+            ));
            if (autoClaude) {
              await github.rest.issues.addLabels({
                issue_number: issue.number,
@@ -29,6 +29,15 @@ output
 threads.db
 threads.db-journal

+# Example run artifacts (generated at runtime, must not be committed)
+examples/**/knowledge.db
+examples/**/knowledge.db-journal
+examples/python/managed-agents/managed_ids.json
+examples/python/save_output/blog_post.md
+examples/python/save_output/generated/
+examples/python/token-metrics/token_metrics_export.json
+examples/python/usecases/market_research_results.json
+
 .chainlit
 !praisonai/ui/config/.chainlit

@@ -232,13 +232,6 @@ Methods:
 * <code title="function">praisonaiagents.<a href="./src/praisonai-agents/praisonaiagents/workflows/workflows.py">repeat</a>(step: Any, until: Optional[Callable[[WorkflowContext], bool]] = None, max_iterations: int = 10) -> Repeat</code>
 * <code title="function">praisonaiagents.<a href="./src/praisonai-agents/praisonaiagents/workflows/workflows.py">route</a>(routes: Dict[str, List], default: Optional[List] = None) -> Route</code>

-# DB
-
-Types:
-```python
-from praisonaiagents import db
-```
-
 # Memory

 Types:
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 HTTP Approval Example
 =====================
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Slack Approval Example
 ======================
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Completions Capability Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Embeddings Capability Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Images Capability Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Moderations Capability Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Energy Industry Template
 ========================
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Transportation Industry Template
 ================================
@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 CI Integration Example - Using Doctor in CI/CD pipelines

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Agent-centric Embedding Example

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 PraisonAI Endpoints Example

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 Fixed example demonstrating proper guardrail usage with PraisonAI Agents.
 This addresses the issues reported in issue #875.
@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 ManagedAgent + ClickHouse Persistence — Real conversation with session resume.

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 ManagedAgent + MongoDB Persistence — Real conversation with session resume.

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 ManagedAgent + MySQL Persistence — Real conversation with session resume.

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 ManagedAgent + PostgreSQL Persistence — Real conversation with session resume.

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 ManagedAgent + Redis Persistence — Real conversation with session resume.

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 ManagedAgent + SQLite Persistence — Real conversation with session resume.

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 Custom Tools MCP Server Example

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 HTTP Stream MCP Server Example

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 MCP Client Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """Multi-Agent Shared Session Demo"""
 from praisonaiagents import Agent
 from praisonai.persistence import create_conversation_store
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Langfuse Integration Example (Updated for TraceSinkProtocol)

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """MLflow Local Observability Demo (no API key needed)"""
 import mlflow
 import time
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 ClickHouse — Persistence Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Minimal Agent with Database Persistence

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 MongoDB StateStore — Full Persistence Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 MySQL ConversationStore — Full Persistence Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 PostgreSQL ConversationStore — Full Persistence Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 PostgreSQL with Runs and Traces

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Redis StateStore — Full Persistence Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Session Resume Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Redis State Store - Agent-First Example

@@ -27,7 +28,7 @@ my_db = db(
 agent = Agent(
    name="Assistant",
    instructions="You are a helpful assistant.",
-    db=my_db,
+    memory=my_db,
    session_id="redis-state-example"
 )

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 PraisonAI A2A Server Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Agent-Centric Autonomy Example.

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 AutoAgents Workflow Patterns Example

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 Context Agent Example - Basic Usage

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Math Agent Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, MCP

 qa_agent = Agent(
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, AgentTeam, Tools

 research_agent = Agent(name="Research", instructions="You are a research agent to search internet about AI 2024", tools=[Tools.internet_search])
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, AgentTeam, Tools

 research_agent = Agent(name="Research", instructions="You are a research agent to search internet about AI 2024", tools=[Tools.internet_search])
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Secondary Market Research FastAPI Application

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, MCP

 search_agent = Agent(
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, AgentTeam
 from duckduckgo_search import DDGS

@@ -2,4 +2,4 @@ from praisonaiagents import Agent

 if __name__ == "__main__":
    agent = Agent(name="TweetAgent", instructions="Create a Tweet based on the topic provided")
-    agent.launch(port=8080, protocol="mcp", path="/")
+    agent.launch(port=8080, protocol="mcp", path="/mcp")
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import AudioAgent

 # Text to Speech
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import AudioAgent

 agent = AudioAgent(llm="openai/tts-1-hd")
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 # Text-to-Speech with OpenAI
 # Requires: export OPENAI_API_KEY=your-key

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import AudioAgent

 agent = AudioAgent(llm="elevenlabs/eleven_multilingual_v2")
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import AudioAgent

 agent = AudioAgent(llm="gemini/gemini-2.5-flash-preview-tts")
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import AudioAgent

 agent = AudioAgent(llm="openai/tts-1")
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Bot Commands Example — Built-in /status, /new, /help commands.

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Bot Gateway Example — Run multiple bots from one gateway server.

@@ -102,7 +102,7 @@ async def demo_with_run_control():
    
    from praisonai.bots._run_control import SessionRunControl
    from praisonai.bots._session import BotSessionManager
-    from praisonai.bots._commands import handle_stop_command
+    from praisonai.bots._commands import handle_stop_command_async
    
    # Session manager with run control
    run_control = SessionRunControl(
@@ -136,7 +136,7 @@ async def demo_with_run_control():
    print("\n3. User decides to stop current task:")
    print("   User: '/stop'")
    
-    stop_response = await handle_stop_command(user_id, run_control)
+    stop_response = await handle_stop_command_async(user_id, run_control)
    print(f"   Bot: {stop_response}")
    
    # Wait for first task to complete (it should be cancelled)
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Standalone gateway example (praisonai-bot first).

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """HTTP Approval — serve a local web dashboard for tool approvals."""

 from praisonaiagents import Agent
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Basic Camera Integration Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Continuous Camera Monitoring Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Multi-Agent Camera Analysis Example

@@ -46,6 +46,6 @@ custom_cmd = SlashCommand(
    alt_names=["mc"]
 )

-handler.register(custom_cmd)
+handler.register_command(custom_cmd)
 result = handler.execute("/mycommand arg1 arg2")
 print(f"\n=== Custom Command ===\n{result.get('message', '')}")
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Claude Code CLI Integration Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Codex CLI Integration Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Cursor CLI Integration Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 External Agents Integration Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Gemini CLI Integration Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 CSV Processing with PraisonAI Agents

@@ -10,6 +10,18 @@ import os
 from praisonaiagents import Agent
 from praisonaiagents.knowledge import Knowledge

+
+def _result_items(results):
+    items = results.results if hasattr(results, "results") else results
+    return list(items)[:3]
+
+
+def _result_text(result):
+    if isinstance(result, dict):
+        return result.get("memory", result.get("text", str(result)))
+    return getattr(result, "text", None) or getattr(result, "memory", None) or str(result)
+
+
 def main():
    """
    Demonstrates knowledge search with and without reranking.
@@ -82,9 +94,9 @@ def main():
    basic_results = basic_knowledge.search(query, rerank=False)
    print(f"Query: {query}")
    print(f"Results (limit=3):")
-    for i, result in enumerate(basic_results[:3]):
-        text = result.get('memory', result.get('text', str(result)))
-        score = result.get('score', 'N/A')
+    for i, result in enumerate(_result_items(basic_results)):
+        text = _result_text(result)
+        score = result.get('score', 'N/A') if isinstance(result, dict) else getattr(result, 'score', 'N/A')
        print(f"  {i+1}. Score: {score}")
        print(f"     Text: {text[:100]}...")
        print()
@@ -94,9 +106,9 @@ def main():
    rerank_results = basic_knowledge.search(query, rerank=True)
    print(f"Query: {query}")
    print(f"Results (limit=3):")
-    for i, result in enumerate(rerank_results[:3]):
-        text = result.get('memory', result.get('text', str(result)))
-        score = result.get('score', 'N/A')
+    for i, result in enumerate(_result_items(rerank_results)):
+        text = _result_text(result)
+        score = result.get('score', 'N/A') if isinstance(result, dict) else getattr(result, 'score', 'N/A')
        print(f"  {i+1}. Score: {score}")
        print(f"     Text: {text[:100]}...")
        print()
@@ -106,9 +118,9 @@ def main():
    default_results = rerank_knowledge.search(query)  # Will use default_rerank=True
    print(f"Query: {query}")
    print(f"Results (limit=3):")
-    for i, result in enumerate(default_results[:3]):
-        text = result.get('memory', result.get('text', str(result)))
-        score = result.get('score', 'N/A')
+    for i, result in enumerate(_result_items(default_results)):
+        text = _result_text(result)
+        score = result.get('score', 'N/A') if isinstance(result, dict) else getattr(result, 'score', 'N/A')
        print(f"  {i+1}. Score: {score}")
        print(f"     Text: {text[:100]}...")
        print()
@@ -125,9 +137,9 @@ def main():
    )
    print(f"Query: {query}")
    print(f"Advanced results with keyword_search=True, filter_memories=True:")
-    for i, result in enumerate(advanced_results[:3]):
-        text = result.get('memory', result.get('text', str(result)))
-        score = result.get('score', 'N/A')
+    for i, result in enumerate(_result_items(advanced_results)):
+        text = _result_text(result)
+        score = result.get('score', 'N/A') if isinstance(result, dict) else getattr(result, 'score', 'N/A')
        print(f"  {i+1}. Score: {score}")
        print(f"     Text: {text[:100]}...")
        print()
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Reasoning Extraction Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, Task, AgentTeam

 agent = Agent(
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Routing Patterns Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Self-Reflection Details Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Simple CSV URL Processor

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Example: Using Latency Tracking Tool with PraisonAI

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 MCP Server with Latency Tracking Example

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+# praisonai: skip=true
 """
 Minimal Example: Latency Tracking for MCP Server

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Model Failover Example - Automatic Provider Switching

@@ -43,9 +44,8 @@ failover_config = FailoverConfig(
    retry_delay=1.0,
    exponential_backoff=True,
    max_retry_delay=60.0,
-    failover_on_rate_limit=True,
-    failover_on_timeout=True,
-    failover_on_error=True,
+    cooldown_on_rate_limit=60.0,
+    cooldown_on_error=30.0,
 )

 # Create failover manager
@@ -62,11 +62,11 @@ def demonstrate_failover():
    
    # Get current status
    status = manager.status()
-    for name, info in status.items():
-        print(f"  {name}:")
-        print(f"    Status: {info.get('status', 'unknown')}")
-        print(f"    Priority: {info.get('priority', 'N/A')}")
-        print(f"    Failures: {info.get('failure_count', 0)}")
+    for profile_info in status.get("profiles", []):
+        print(f"  {profile_info.get('name', 'unknown')}:")
+        print(f"    Status: {profile_info.get('status', 'unknown')}")
+        print(f"    Priority: {profile_info.get('priority', 'N/A')}")
+        print(f"    Last error: {profile_info.get('last_error') or 'none'}")
    print()
    
    # Get next available profile
@@ -163,7 +163,7 @@ if __name__ == "__main__":
        print(f"  {profile.name}:")
        print(f"    Provider: {profile.provider}")
        print(f"    Priority: {profile.priority}")
-        print(f"    Rate limit: {profile.rate_limit} req/min")
+        print(f"    Rate limit: {profile.rate_limit_rpm} req/min")
    print()
    
    demonstrate_failover()
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Advanced Callback Systems Example

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 import asyncio
 import time
 from typing import List, Dict
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 import asyncio
 import time
 from typing import List, Dict
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 import asyncio
 import time
 from typing import List, Dict
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, Task, AgentTeam
 import json
 from e2b_code_interpreter import Sandbox
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import (
    Agent, 
    Task, 
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, Task, AgentTeam
 from typing import List, Dict, Union
 from duckduckgo_search import DDGS
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, Task, AgentTeam, error_logs
 from duckduckgo_search import DDGS

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, Task, AgentTeam
 from langchain_community.tools import YouTubeSearchTool
 from langchain_community.utilities import WikipediaAPIWrapper
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, Task, AgentTeam
 from datetime import datetime
 import asyncio
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent
 from pydantic import BaseModel
 from typing import List, Optional
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, Task, AgentTeam
 from praisonaiagents.tools import get_article, get_news_sources, get_articles_from_source, get_trending_topics

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import Agent, Task, AgentTeam
 from typing import List, Dict
 from duckduckgo_search import DDGS
@@ -12,8 +12,7 @@ Features demonstrated:
 - Quality assurance workflows
 """

-from praisonaiagents import Agent, Task, AgentTeam
-from praisonaiagents.task import TaskOutput
+from praisonaiagents import Agent, Task, AgentTeam, TaskOutput
 from typing import Tuple, Any
 import re

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Production Guardrails Patterns Example

@@ -31,7 +31,6 @@ billing_agent = Agent(
    role="Billing Specialist",
    goal="Handle all billing-related inquiries and tasks using structured data",
    backstory="I am an expert in billing systems, payment processing, and invoice management.",
-    input_payload_schema=BillingPayload  # hypothetical but consistent with design
 )

 refund_agent = Agent(
@@ -39,7 +38,6 @@ refund_agent = Agent(
    role="Refund Specialist",
    goal="Process refund requests and handle refund-related issues with validated data",
    backstory="I specialize in processing refunds, evaluating refund eligibility, and ensuring customer satisfaction.",
-    input_payload_schema=RefundPayload
 )

 technical_support_agent = Agent(
@@ -47,7 +45,6 @@ technical_support_agent = Agent(
    role="Technical Support Specialist",
    goal="Resolve technical issues and provide technical assistance with structured context",
    backstory="I am skilled in troubleshooting technical problems and providing solutions.",
-    input_payload_schema=TechnicalPayload
 )

 # Create a triage agent with typed handoffs
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Unified Handoff Configuration Example.

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 from praisonaiagents import ImageAgent

 agent = ImageAgent(llm="openai/dall-e-3", style="vivid")
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 # Image Generation with DALL-E
 # Requires: export OPENAI_API_KEY=your-key

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Streamlit UI Input Example for PraisonAI

@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Linear Agent Example for PraisonAI.