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-09 03:39:37 -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
381 changed files with 9446 additions and 5822 deletions
@@ -40,6 +40,62 @@ assert('claude final reply detected', mg.isClaudeFinalReplyComment(withClaudeRep

 assert('cancelled detect-and-trigger does not block', mg.OPTIONAL_CANCELLED_CHECKS.has('detect-and-trigger'));

+const coreGreenRuns = [
+  { name: 'test-core', status: 'completed', conclusion: 'success' },
+  { name: 'test-core (cli)', status: 'completed', conclusion: 'success' },
+  { name: 'smoke', status: 'completed', conclusion: 'cancelled' },
+  { name: 'test-windows', status: 'completed', conclusion: 'cancelled' },
+];
+assert('core green allows cancelled smoke', mg.isAcceptableCheckConclusion(
+  { name: 'smoke', status: 'completed', conclusion: 'cancelled' },
+  coreGreenRuns
+));
+assert('core green allows cancelled test-windows', mg.isAcceptableCheckConclusion(
+  { name: 'test-windows', status: 'completed', conclusion: 'cancelled' },
+  coreGreenRuns
+));
+assert('cancelled smoke blocks when core missing', !mg.isAcceptableCheckConclusion(
+  { name: 'smoke', status: 'completed', conclusion: 'cancelled' },
+  [{ name: 'smoke', status: 'completed', conclusion: 'cancelled' }]
+));
+assert('cancelled smoke blocks when core failed', !mg.isAcceptableCheckConclusion(
+  { name: 'smoke', status: 'completed', conclusion: 'cancelled' },
+  [
+    { name: 'test-core', status: 'completed', conclusion: 'failure' },
+    { name: 'smoke', status: 'completed', conclusion: 'cancelled' },
+  ]
+));
+assert('bestRunsByName prefers success over cancelled', (() => {
+  const best = mg.bestRunsByName([
+    { name: 'smoke', conclusion: 'cancelled' },
+    { name: 'smoke', conclusion: 'success' },
+  ]);
+  return best.length === 1 && best[0].conclusion === 'success';
+})());
+assert('bestRunsByName prefers pending over completed cancelled', (() => {
+  const best = mg.bestRunsByName([
+    { name: 'smoke', status: 'completed', conclusion: 'cancelled' },
+    { name: 'smoke', status: 'in_progress', conclusion: null },
+  ]);
+  return best.length === 1 && best[0].status === 'in_progress';
+})());
+assert('bestRunsByName keeps pending regardless of order', (() => {
+  const best = mg.bestRunsByName([
+    { name: 'smoke', status: 'in_progress', conclusion: null },
+    { name: 'smoke', status: 'completed', conclusion: 'success' },
+  ]);
+  return best.length === 1 && best[0].status === 'in_progress';
+})());
+assert('allChecksGreenOnSha style: pending re-run blocks despite core green', (() => {
+  const runs = mg.bestRunsByName([
+    { name: 'test-core', status: 'completed', conclusion: 'success' },
+    { name: 'smoke', status: 'completed', conclusion: 'cancelled' },
+    { name: 'smoke', status: 'queued', conclusion: null },
+  ]);
+  const smoke = runs.find((r) => r.name === 'smoke');
+  return smoke.status !== 'completed';
+})());
+
 // Stale-FINAL recovery guards (PR #2560 push loop)
 const nowMs = Date.now();
 const iso = (ms) => new Date(ms).toISOString();
@@ -44,6 +44,8 @@ const BLOCK_LABELS = new Set([
 const MERGE_READY_LABEL = 'pipeline/merge-ready';
 /** Superseded concurrency runs; must not block merge when real tests passed. */
 const OPTIONAL_CANCELLED_CHECKS = new Set(['detect-and-trigger']);
+/** Cancelled smoke/windows after timeout are non-blocking when core shards passed on HEAD. */
+const OPTIONAL_CANCELLED_WHEN_CORE_GREEN = new Set(['smoke', 'test-windows']);
 const BOT_REVIEWER_PATTERNS = [
  'coderabbit',
  'qodo',
@@ -325,8 +327,70 @@ function listFailedChecksOnSha(runs) {
  });
 }

+function isCoreTestRun(run) {
+  const name = run?.name || '';
+  return name === 'test-core' || name.startsWith('test-core ') || name === 'test-core-collect';
+}
+
+function coreTestsGreenOnRuns(runs) {
+  const coreRuns = (runs || []).filter(isCoreTestRun);
+  if (coreRuns.length === 0) return false;
+  return coreRuns.every(
+    (run) =>
+      run.status === 'completed' &&
+      ['success', 'neutral', 'skipped'].includes(run.conclusion)
+  );
+}
+
+function checkConclusionRank(conclusion) {
+  if (conclusion === 'success') return 4;
+  if (conclusion === 'neutral') return 3;
+  if (conclusion === 'skipped') return 2;
+  if (conclusion === 'cancelled') return 1;
+  return 0;
+}
+
+function isPendingRun(run) {
+  return !!(run && run.status && run.status !== 'completed');
+}
+
+function bestRunsByName(runs) {
+  const byName = new Map();
+  for (const run of runs || []) {
+    if (!run) continue;
+    const existing = byName.get(run.name);
+    if (!existing) {
+      byName.set(run.name, run);
+      continue;
+    }
+    const runPending = isPendingRun(run);
+    const existingPending = isPendingRun(existing);
+    if (existingPending) continue;
+    if (
+      runPending ||
+      checkConclusionRank(run.conclusion) > checkConclusionRank(existing.conclusion)
+    ) {
+      byName.set(run.name, run);
+    }
+  }
+  return [...byName.values()];
+}
+
+function isAcceptableCheckConclusion(run, runs) {
+  if (['success', 'neutral', 'skipped'].includes(run.conclusion)) return true;
+  if (run.conclusion === 'cancelled' && OPTIONAL_CANCELLED_CHECKS.has(run.name)) return true;
+  if (
+    run.conclusion === 'cancelled' &&
+    OPTIONAL_CANCELLED_WHEN_CORE_GREEN.has(run.name) &&
+    coreTestsGreenOnRuns(runs)
+  ) {
+    return true;
+  }
+  return false;
+}
+
 async function allChecksGreenOnSha(github, owner, repo, sha, core) {
-  const runs = await listChecksOnSha(github, owner, repo, sha);
+  const runs = bestRunsByName(await listChecksOnSha(github, owner, repo, sha));
  if (runs.length === 0) {
    core?.info?.(`No check runs on ${sha.slice(0, 7)} — allowing (e.g. docs-only PR)`);
    return true;
@@ -336,13 +400,17 @@ async function allChecksGreenOnSha(github, owner, repo, sha, core) {
      core?.info?.(`Check pending: ${run.name} (${run.status})`);
      return false;
    }
-    const ok =
-      ['success', 'neutral', 'skipped'].includes(run.conclusion) ||
-      (run.conclusion === 'cancelled' && OPTIONAL_CANCELLED_CHECKS.has(run.name));
-    if (!ok) {
+    if (!isAcceptableCheckConclusion(run, runs)) {
      core?.info?.(`Check failed: ${run.name} (${run.conclusion})`);
      return false;
    }
+    if (
+      run.conclusion === 'cancelled' &&
+      OPTIONAL_CANCELLED_WHEN_CORE_GREEN.has(run.name) &&
+      coreTestsGreenOnRuns(runs)
+    ) {
+      core?.info?.(`Ignoring cancelled ${run.name} — test-core green on HEAD`);
+    }
  }
  return true;
 }
@@ -855,6 +923,12 @@ module.exports = {
  finalClaudeCompletedOnSha,
  getMergeState,
  OPTIONAL_CANCELLED_CHECKS,
+  OPTIONAL_CANCELLED_WHEN_CORE_GREEN,
+  isCoreTestRun,
+  coreTestsGreenOnRuns,
+  isPendingRun,
+  bestRunsByName,
+  isAcceptableCheckConclusion,
  listChecksOnSha,
  listFailedChecksOnSha,
  allChecksGreenOnSha,
@@ -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,
@@ -0,0 +1,47 @@
+name: Terminal-Bench Smoke
+
+# Manual (and optional weekly) smoke run of the `praisonai code` assistant on a
+# small verified Terminal-Bench 2.1 subset via the Harbor harness.
+# Never runs on PRs — it costs money (LLM calls) and is inherently flaky.
+
+on:
+  workflow_dispatch:
+  schedule:
+    - cron: "0 6 * * 1" # Mondays 06:00 UTC
+
+permissions:
+  contents: read
+
+jobs:
+  smoke:
+    runs-on: ubuntu-latest
+    timeout-minutes: 45
+    steps:
+      - uses: actions/checkout@v4
+
+      - uses: actions/setup-python@v5
+        with:
+          python-version: "3.11"
+
+      - name: Install Harbor + PraisonAI
+        run: |
+          python -m pip install --upgrade pip
+          pip install harbor
+          pip install -e src/praisonai-agents -e src/praisonai
+
+      - name: Run Terminal-Bench 2.1 smoke subset
+        env:
+          OPENAI_API_KEY: ${{ secrets.OPENAI_API_KEY }}
+          PYTHONPATH: .
+        run: |
+          harbor run -c examples/terminal_bench/job_code_smoke.yaml || true
+
+      - name: Upload Harbor results
+        if: always()
+        uses: actions/upload-artifact@v4
+        with:
+          name: harbor-results
+          path: |
+            runs/
+            **/results.json
+          if-no-files-found: warn
@@ -42,7 +42,7 @@ jobs:
  # ============================================
  smoke:
    runs-on: ubuntu-latest
-    timeout-minutes: 8
+    timeout-minutes: 12
    steps:
    - uses: actions/checkout@v4
      with:
@@ -20,7 +20,7 @@ on:
 jobs:
  test-windows:
    runs-on: windows-latest
-    timeout-minutes: 5
+    timeout-minutes: 10
    env:
      OPENAI_API_KEY: ${{ secrets.OPENAI_API_KEY }}
      OPENAI_MODEL_NAME: gpt-4o-mini
@@ -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

@@ -19,7 +20,9 @@ def run_doctor_ci():
        [sys.executable, "-m", "praisonai", "doctor", "ci"],
        capture_output=True,
        text=True,
-        timeout=120
+        encoding="utf-8",
+        errors="replace",
+        timeout=120,
    )
    
    # Parse JSON output
@@ -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.
@@ -149,21 +149,28 @@ def main():
            
            print(f"\nOriginal document length: {len(content)} characters")
            
+            chunks = [{"text": content, "metadata": {"source": doc_path}}]
+            target_tokens = 2000
+
            # Compress with different ratios
            for ratio in [0.3, 0.5, 0.7]:
-                compressor = ContextCompressor(
-                    max_tokens=2000,
-                    target_ratio=ratio,
+                compressor = ContextCompressor(verbose=False)
+                result = compressor.compress(
+                    chunks,
+                    query="security verification code",
+                    target_tokens=target_tokens,
+                    compression_ratio=ratio,
                )
-                result = compressor.compress([content], query="security verification code")
                
                print(f"\nCompression ratio {ratio}:")
                print(f"  Original tokens: {result.original_tokens}")
                print(f"  Compressed tokens: {result.compressed_tokens}")
-                print(f"  Actual ratio: {result.compressed_tokens / max(result.original_tokens, 1):.2f}")
+                print(f"  Actual ratio: {result.compression_ratio:.2f}")
                
                # Check if secret code is preserved
-                compressed_text = " ".join(result.chunks) if result.chunks else ""
+                compressed_text = " ".join(
+                    c.get("text", "") for c in result.chunks
+                ) if result.chunks else ""
                if SECRET_CODE in compressed_text:
                    print(f"  ✅ Secret code preserved in compressed output")
                else:
@@ -65,7 +65,6 @@ def main():
            name="Policy_Expert",
            instructions="You are a policy expert.",
            knowledge=[temp_dir],
-            agent_id="policy_agent_v1",  # Knowledge scoped to this agent
        )
        
        response = shared_agent.chat("What are the expense report rules?")
@@ -81,7 +80,6 @@ def main():
            instructions="You are a personal HR assistant.",
            knowledge=[temp_dir],
            memory={"user_id": "user_bob"},
-            agent_id="hr_bot_v2",
        )
        
        response = combined_agent.chat("What training is required?")
@@ -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

@@ -13,7 +14,8 @@ Expected Output:
    Agent responds with state persisted to Redis
 """

-from praisonaiagents import Agent, db
+from praisonaiagents import Agent
+from praisonaiagents.db import db

 print("=== Redis State Store (Agent-First) ===")

@@ -26,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"
 )

@@ -61,7 +61,7 @@ def demonstrate_collision_problem():
    _reset_default_registry()
    
    # Agent 1 registers "custom" provider
-    register_llm_provider("custom", Agent1Provider)
+    register_llm_provider("custom", Agent1Provider, override=True)
    print("Agent 1 registered 'custom' provider")
    
    # Agent 2 tries to register same name - ERROR!
@@ -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,5 @@
+# praisonai: skip=true
+# Uses removed praisonaiagents.tools exports; pending example refresh
 from praisonaiagents import Agent, Tools
 from praisonaiagents.tools import read_csv, read_excel, write_csv, write_excel, filter_data, get_summary, group_by, pivot_table
 import os
@@ -7,4 +9,4 @@ agent.start(f"""
    Read the data from the csv file {os.path.join(os.path.dirname(__file__), "tesla-stock-price.csv")}
    Analyse the data and give me the insights
    read_csv to read the file
-""")
+""")
@@ -1,5 +1,7 @@
+# praisonai: skip=true
+# Uses removed praisonaiagents.tools exports; pending example refresh
 from praisonaiagents import Agent, Tools
 from praisonaiagents.tools import get_stock_price, get_stock_info, get_historical_data

 agent = Agent(instructions="You are a Research Agent", tools=[get_stock_price, get_stock_info, get_historical_data])
-agent.start("Understand current stock price and historical data of Apple and Google. Tell me if I can invest in them")
+agent.start("Understand current stock price and historical data of Apple and Google. Tell me if I can invest in them")
@@ -1,3 +1,4 @@
+# praisonai: skip=true
 """
 Math Agent Example

@@ -135,7 +135,7 @@ def example_auto_agents_multi_provider():
    from praisonaiagents.agents import AutoAgents
    
    # Create AutoAgents that will automatically assign appropriate models
-    auto_agents = AutoAgentTeam(
+    auto_agents = AutoAgents(
        instructions="Create a market research report on electric vehicles. Include data analysis, competitor analysis, and future projections.",
        max_agents=3,
        llm="gpt-4o-mini",  # Default model for agent generation
@@ -1,3 +1,5 @@
+# praisonai: skip=true
+# Uses removed praisonaiagents.tools exports; pending example refresh
 from praisonaiagents import Agent, Task, AgentTeam
 from praisonaiagents.tools import wiki_search, wiki_summary, wiki_page, wiki_random, wiki_language

@@ -13,4 +15,4 @@ agent.start(
    "First search the history of AI"
    "Read the page of the history of AI"
    "Get the summary of the page"
-)
+)
@@ -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,5 @@
+# praisonai: skip=true
+# Requires local audio.mp3 fixture
 from praisonaiagents import AudioAgent

 agent = AudioAgent(llm="groq/whisper-large-v3")  # 10x faster
@@ -5,3 +7,4 @@ text = agent.transcribe("audio.mp3", language="en")
 print(text)

 # Models: openai/whisper-1, groq/whisper-large-v3, deepgram/nova-2
+
@@ -1,3 +1,5 @@
+# praisonai: skip=true
+# Requires local audio.mp3 fixture
 # Speech-to-Text with Groq (fastest)
 # Requires: export GROQ_API_KEY=your-key

@@ -6,3 +8,4 @@ from praisonaiagents import AudioAgent
 agent = AudioAgent(llm="groq/whisper-large-v3")
 text = agent.listen("audio.mp3")  # Replace with your audio file
 print(text)
+
@@ -1,5 +1,8 @@
+# praisonai: skip=true
+# Requires local audio.mp3 fixture
 from praisonaiagents import AudioAgent

 agent = AudioAgent(llm="deepgram/nova-2")
 text = agent.listen("audio.mp3")
 print(text)
+
@@ -1,5 +1,8 @@
+# praisonai: skip=true
+# Requires local audio.mp3 fixture
 from praisonaiagents import AudioAgent

 agent = AudioAgent(llm="groq/whisper-large-v3")
 text = agent.listen("audio.mp3")
 print(text)
+
@@ -1,5 +1,8 @@
+# praisonai: skip=true
+# Requires local audio.mp3 fixture
 from praisonaiagents import AudioAgent

 agent = AudioAgent(llm="openai/whisper-1")
 text = agent.listen("audio.mp3")
 print(text)
+
@@ -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