fix(ci): resolve all ruff lint errors for green CI

Made-with: Cursor

Author: sukethrp

examples/auth_demo.py

@@ -2,7 +2,6 @@
 
 import os
 import sys
-import time
 
 sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", "src"))
 

examples/branching_demo.py

@@ -160,7 +160,7 @@ def main():
     # Show the merge summary
     merge_msg = tree.get_messages()[-1]
     if merge_msg.role == "system":
-        print(f"\n   Merge context preview:")
+        print("\n   Merge context preview:")
         for line in merge_msg.content.split("\n")[:8]:
             print(f"      {line}")
         print("      ...")

examples/demo_mode.py

@@ -107,7 +107,7 @@ def company_lookup(company_name: str) -> str:
     print(f"   Queries run:     {len(DEMO_QUERIES)}")
     print(f"   Total tokens:    {total_tokens:,}")
     print(f"   Total cost:      ${total_cost:.4f} (simulated)")
-    print(f"   Provider:        MockProvider (no API keys)")
+    print("   Provider:        MockProvider (no API keys)")
     print(f"{'=' * 60}")
     print()
     print("💡 To start the full web platform in demo mode:")

examples/event_demo.py

@@ -16,7 +16,6 @@
 from agentos.tools import get_builtin_tools
 from agentos.events import (
     event_bus,
-    WebhookTrigger,
     TimerTrigger,
     AgentCompleteTrigger,
 )
@@ -219,9 +218,15 @@ def on_custom(event):
 
     print()
     print("   Registered listeners:")
-    for l in event_bus.list_listeners():
-        agent_name = getattr(l.agent, "config", None) and l.agent.config.name or "callback"
-        print(f"     • {l.event_pattern:25s} → {agent_name} (ran {l.execution_count}x)")
+    for listener in event_bus.list_listeners():
+        agent_name = (
+            getattr(listener.agent, "config", None)
+            and listener.agent.config.name
+            or "callback"
+        )
+        print(
+            f"     • {listener.event_pattern:25s} → {agent_name} (ran {listener.execution_count}x)"
+        )
 
     # Clean up
     event_bus.clear()

examples/full_demo.py

@@ -152,7 +152,7 @@ def send_email(to: str, subject: str) -> str:
     # Print final stats
     stats = agent.get_stats()
     print(f"\n{'='*60}")
-    print(f"📊 Final Agent Stats")
+    print("📊 Final Agent Stats")
     print(f"{'='*60}")
     print(f"   Agent:       {stats['name']}")
     print(f"   Model:       {stats['model']}")

examples/learning_demo.py

@@ -45,7 +45,7 @@ def main() -> None:
     print("=" * 60)
 
     # Use in-memory store (temp dir) so we don't pollute the real data
-    import tempfile, os
+    import tempfile
     tmp = tempfile.mkdtemp()
     store = FeedbackStore(data_dir=tmp)
 
@@ -155,7 +155,7 @@ def _seed(rows, time_offset=0):
         for line in p.instruction.split("\n")[:4]:
             print(f"     {line}")
         if len(p.instruction.split("\n")) > 4:
-            print(f"     …")
+            print("     …")
 
     # Show the optimised prompt
     base_prompt = "You are a helpful customer support assistant."

examples/marketplace_demo.py

@@ -6,7 +6,8 @@
 
 from __future__ import annotations
 
-import sys, os
+import sys
+import os
 sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", "src"))
 
 from agentos.marketplace import MarketplaceStore, AgentConfig

examples/multimodal_demo.py

@@ -18,10 +18,13 @@
 
 load_dotenv()
 
-from agentos.core.agent import Agent
-from agentos.core.multimodal import analyze_image, read_document, extract_text_from_pdf
-from agentos.tools.vision_tool import vision_tool
-from agentos.tools.document_tool import document_reader_tool, document_qa_tool
+from agentos.core.agent import Agent  # noqa: E402
+from agentos.core.multimodal import analyze_image, read_document  # noqa: E402
+from agentos.tools.vision_tool import vision_tool  # noqa: E402
+from agentos.tools.document_tool import (  # noqa: E402
+    document_reader_tool,
+    document_qa_tool,
+)
 
 
 def demo_image_analysis():

examples/observability_demo.py

@@ -23,7 +23,6 @@
     Trace,
     TraceBuilder,
     TraceStore,
-    StepType,
 )
 from agentos.observability.diagnostics import diagnose, diagnose_batch
 from agentos.observability.alerts import AlertEngine
@@ -264,8 +263,8 @@ def main() -> None:
     print(f"   Traces: {len(store.list_all())}")
     print(f"   Diagnoses: {len(all_diags)}")
     print(f"   Alerts: {len(alerts)}")
-    print(f"   5-point diagnostic checks: context, tool selection,")
-    print(f"     tool execution, interpretation, faithfulness")
+    print("   5-point diagnostic checks: context, tool selection,")
+    print("     tool execution, interpretation, faithfulness")
     print(f"{'=' * 60}")
 
 

examples/plugin_demo.py

@@ -140,5 +140,5 @@ def divider(title: str) -> None:
     print(f"   Tools available: {len(all_tools)} (built-in: {len(builtin_tools)}, plugins: {len(plugin_tools)})")
     print()
     print(f"{'=' * 60}")
-    print(f"  ✅ Plugin demo complete")
+    print("  ✅ Plugin demo complete")
     print(f"{'=' * 60}")