Merge pull request #16 from tarun-etikala/feat/ruff-linting

Feat/ruff linting

Author: tarun-etikala

.github/workflows/ruff.yml

@@ -0,0 +1,38 @@
+name: Ruff
+
+on:
+  push:
+    branches: [main]
+  pull_request:
+    branches: [main]
+  workflow_dispatch:
+
+permissions: {}
+
+concurrency:
+  group: ruff-${{ github.ref }}
+  cancel-in-progress: true
+
+jobs:
+  lint:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+    timeout-minutes: 10
+    steps:
+      - name: Checkout
+        uses: actions/checkout@34e114876b0b11c390a56381ad16ebd13914f8d5  # v4.3.1
+
+      - name: Setup Python
+        uses: actions/setup-python@a26af69be951a213d495a4c3e4e4022e16d87065  # v5.6.0
+        with:
+          python-version: "3.12"
+
+      - name: Install ruff
+        run: pip install ruff==0.15.11
+
+      - name: Ruff lint
+        run: ruff check . --output-format=github
+
+      - name: Ruff format check
+        run: ruff format --check .

CONTRIBUTING.md

@@ -14,6 +14,21 @@ Thank you for your interest in contributing. This document gives a short overvie
 
 Before submitting, please read our [Code of Conduct](CODE_OF_CONDUCT.md). By participating, you agree to uphold it.
 
+## Linting and formatting
+
+This project uses [ruff](https://docs.astral.sh/ruff/) for Python linting and formatting. CI runs ruff as a blocking check on all pull requests.
+
+Run locally before pushing:
+
+```bash
+pip install ruff
+ruff check .          # lint
+ruff format --check . # format check
+ruff format .         # auto-format
+```
+
+Configuration is in [`ruff.toml`](ruff.toml) at the repo root.
+
 ## Commit message conventions
 
 We encourage [Conventional Commits](https://www.conventionalcommits.org/) so that history and release notes stay clear.

agents/a2a/langgraph_crewai_agent/src/a2a_langgraph_crewai/a2a_reply.py

@@ -9,7 +9,6 @@
 from uuid import uuid4
 
 import httpx
-
 from a2a.client import A2ACardResolver, A2AClient
 from a2a.types import (
     JSONRPCErrorResponse,

agents/a2a/langgraph_crewai_agent/src/a2a_langgraph_crewai/crew_a2a_server.py

@@ -12,16 +12,15 @@
 from os import getenv
 
 import uvicorn
-from crewai import Agent, Crew, LLM, Task
-from dotenv import load_dotenv
-
 from a2a.server.agent_execution import AgentExecutor, RequestContext
 from a2a.server.apps import A2AStarletteApplication
 from a2a.server.events import EventQueue
 from a2a.server.request_handlers import DefaultRequestHandler
 from a2a.server.tasks import InMemoryTaskStore
 from a2a.types import AgentCapabilities, AgentCard, AgentSkill
 from a2a.utils import new_agent_text_message
+from crewai import LLM, Agent, Crew, Task
+from dotenv import load_dotenv
 
 from .custom_tool import DummyWebSearchTool
 

agents/a2a/langgraph_crewai_agent/src/a2a_langgraph_crewai/langgraph_a2a_server.py

@@ -13,24 +13,13 @@
 import json
 import logging
 import time
+from collections.abc import AsyncIterator
 from os import getenv
 from pathlib import Path
-from collections.abc import AsyncIterator
 from typing import Any
 from uuid import uuid4
 
 import uvicorn
-from dotenv import load_dotenv
-from langchain.agents import create_agent
-from langchain_core.messages import AIMessage, HumanMessage
-from langchain_core.tools import tool
-from langchain_openai import ChatOpenAI
-from starlette.applications import Starlette
-from starlette.exceptions import HTTPException
-from starlette.requests import Request
-from starlette.responses import FileResponse, JSONResponse, StreamingResponse
-from starlette.routing import Route
-
 from a2a.server.agent_execution import AgentExecutor, RequestContext
 from a2a.server.apps import A2AStarletteApplication
 from a2a.server.events import EventQueue
@@ -44,6 +33,16 @@
     SendMessageRequest,
 )
 from a2a.utils import new_agent_text_message
+from dotenv import load_dotenv
+from langchain.agents import create_agent
+from langchain_core.messages import AIMessage, HumanMessage
+from langchain_core.tools import tool
+from langchain_openai import ChatOpenAI
+from starlette.applications import Starlette
+from starlette.exceptions import HTTPException
+from starlette.requests import Request
+from starlette.responses import FileResponse, JSONResponse, StreamingResponse
+from starlette.routing import Route
 
 from .a2a_reply import send_a2a_text_message
 
@@ -278,7 +277,8 @@ async def _stream_orchestrator_sse(
                     tool_calls = getattr(message, "tool_calls", None) or []
                     if tool_calls:
                         tool_calls_delta = [
-                            _tool_call_to_delta(tc, i) for i, tc in enumerate(tool_calls)
+                            _tool_call_to_delta(tc, i)
+                            for i, tc in enumerate(tool_calls)
                         ]
                         data = {
                             "id": completion_id,

agents/autogen/mcp_agent/main.py

@@ -8,6 +8,8 @@
 from os import getenv
 from pathlib import Path
 
+from autogen_agent_base.agent import get_agent_chat
+from autogen_agent_base.tracing import enable_tracing
 from autogen_agentchat.base._task import TaskResult
 from autogen_agentchat.messages import (
     ModelClientStreamingChunkEvent,
@@ -24,12 +26,14 @@
 )
 from dotenv import load_dotenv
 from fastapi import FastAPI, HTTPException
-from fastapi.responses import FileResponse, HTMLResponse, JSONResponse, StreamingResponse
+from fastapi.responses import (
+    FileResponse,
+    HTMLResponse,
+    JSONResponse,
+    StreamingResponse,
+)
 from pydantic import BaseModel, Field, model_validator
 
-from autogen_agent_base.agent import get_agent_chat
-from autogen_agent_base.tracing import enable_tracing
-
 load_dotenv()
 
 
@@ -227,9 +231,7 @@ def _invocation_row(call, res) -> dict:
     """Pair FunctionCall + FunctionExecutionResult for API / playground."""
     args_raw = getattr(call, "arguments", "") or ""
     try:
-        args_out: str | dict | list = (
-            json.loads(args_raw) if args_raw.strip() else {}
-        )
+        args_out: str | dict | list = json.loads(args_raw) if args_raw.strip() else {}
     except json.JSONDecodeError:
         args_out = args_raw
     content = (getattr(res, "content", None) or "") or ""

agents/autogen/mcp_agent/mcp_automl_template/interact_with_mcp.py

@@ -1,12 +1,12 @@
 import asyncio
 import textwrap
 from os import getenv
-from utils import get_chat_from_env
-from mcp import ClientSession
-from mcp.client.sse import sse_client
 
 from langchain_mcp_adapters.tools import load_mcp_tools
 from langgraph.prebuilt import create_react_agent
+from mcp import ClientSession
+from mcp.client.sse import sse_client
+from utils import get_chat_from_env
 
 # LLM from .env: BASE_URL, MODEL_ID, API_KEY (see repo template.env; Ollama example there)
 chat_openai = get_chat_from_env()

agents/autogen/mcp_agent/mcp_automl_template/mcp_server.py

@@ -4,8 +4,9 @@
 from dotenv import load_dotenv
 from mcp.server.fastmcp import FastMCP
 from mcp.server.transport_security import TransportSecuritySettings
-
 from register_tools import register_tools_from_config
+from starlette.requests import Request
+from starlette.responses import JSONResponse
 
 load_dotenv()
 
@@ -26,9 +27,6 @@
     transport_security=_transport_security,
 )
 
-from starlette.requests import Request
-from starlette.responses import JSONResponse
-
 
 @mcp.custom_route("/health", methods=["GET"])
 async def health(request: Request) -> JSONResponse:

agents/autogen/mcp_agent/mcp_automl_template/register_tools.py

@@ -13,7 +13,6 @@
 
 import httpx
 import yaml
-
 from utils import json_schema_to_pydantic_model
 
 

agents/autogen/mcp_agent/mcp_automl_template/utils.py

@@ -1,10 +1,10 @@
-from typing import Literal
-from pydantic import BaseModel, create_model
 import json
 from os import getenv
-import pandas as pd
+from typing import Literal
 
+import pandas as pd
 from dotenv import load_dotenv
+from pydantic import BaseModel, create_model
 
 load_dotenv()