fix ci

Author: supreme-gg-gg

go/test/e2e/invoke_api_test.go

@@ -630,8 +630,8 @@ func TestE2EInvokeOpenAIAgent(t *testing.T) {
 	require.NoError(t, cmd.Run())
 
 	defer func() {
-		cli.Delete(t.Context(), agent)
-		cli.Delete(t.Context(), modelCfg)
+		cli.Delete(t.Context(), agent) //nolint:errcheck
+		cli.Delete(t.Context(), modelCfg) //nolint:errcheck
 	}()
 
 	// Setup A2A client - use the agent's actual name

python/packages/kagent-crewai/src/kagent/crewai/_a2a.py

@@ -9,11 +9,11 @@
 from a2a.types import AgentCard
 from fastapi import FastAPI, Request
 from fastapi.responses import PlainTextResponse
+from kagent.core import KAgentConfig, configure_tracing
+from kagent.core.a2a import KAgentRequestContextBuilder, KAgentTaskStore
 from opentelemetry.instrumentation.crewai import CrewAIInstrumentor
 
 from crewai import Crew, Flow
-from kagent.core import KAgentConfig, configure_tracing
-from kagent.core.a2a import KAgentRequestContextBuilder, KAgentTaskStore
 
 from ._executor import CrewAIAgentExecutor, CrewAIAgentExecutorConfig
 

python/packages/kagent-crewai/src/kagent/crewai/_listeners.py

@@ -15,6 +15,12 @@
     TaskStatusUpdateEvent,
     TextPart,
 )
+from kagent.core.a2a import (
+    A2A_DATA_PART_METADATA_TYPE_FUNCTION_CALL,
+    A2A_DATA_PART_METADATA_TYPE_FUNCTION_RESPONSE,
+    A2A_DATA_PART_METADATA_TYPE_KEY,
+    get_kagent_metadata_key,
+)
 
 from crewai.events import (
     AgentExecutionCompletedEvent,
@@ -27,12 +33,6 @@
     ToolUsageFinishedEvent,
     ToolUsageStartedEvent,
 )
-from kagent.core.a2a import (
-    A2A_DATA_PART_METADATA_TYPE_FUNCTION_CALL,
-    A2A_DATA_PART_METADATA_TYPE_FUNCTION_RESPONSE,
-    A2A_DATA_PART_METADATA_TYPE_KEY,
-    get_kagent_metadata_key,
-)
 
 
 class A2ACrewAIListener(BaseEventListener):

python/packages/kagent-openai/__init__.py

@@ -16,7 +16,7 @@
 from a2a.server.request_handlers import DefaultRequestHandler
 from a2a.server.tasks import InMemoryTaskStore
 from a2a.types import AgentCard
-from agents import Agent
+from agents import Agent, set_tracing_disabled
 from fastapi import FastAPI, Request
 from fastapi.responses import PlainTextResponse
 from kagent.core import KAgentConfig, configure_tracing
@@ -143,6 +143,9 @@ def build(self) -> FastAPI:
 
         if self.tracing:
             try:
+                # Set OpenAI tracing disabled and set custom OTEL tracing to be enabled
+                logger.info("Configuring tracing for KAgent OpenAI app")
+                set_tracing_disabled(True)
                 configure_tracing(app)
 
                 # Configure tracing for OpenAI Agents SDK

python/packages/kagent-openai/src/kagent/openai/_a2a.py

@@ -1,3 +1,5 @@
 # KAgent Skills
 
 Core library for discovering, parsing, and loading KAgent skills from the filesystem.
+
+For example usage, see `kagent-adk` and `kagent-openai` packages.

python/packages/kagent-skills/README.md

@@ -1,5 +1,4 @@
-from .discovery import discover_skills
-from .loader import load_skill_content
+from .discovery import discover_skills, load_skill_content
 from .models import Skill
 from .prompts import (
     generate_skills_tool_description,

python/packages/kagent-skills/src/kagent/skills/__init__.py

@@ -58,3 +58,23 @@ def discover_skills(skills_directory: Path) -> list[Skill]:
             logger.error(f"Failed to parse skill {skill_dir.name}: {e}")
 
     return skills
+
+
+def load_skill_content(skills_directory: Path, skill_name: str) -> str:
+    """Load and return the full content of a skill's SKILL.md file."""
+    # Find skill directory
+    skill_dir = skills_directory / skill_name
+    if not skill_dir.exists() or not skill_dir.is_dir():
+        raise FileNotFoundError(f"Skill '{skill_name}' not found in {skills_directory}")
+
+    skill_file = skill_dir / "SKILL.md"
+    if not skill_file.exists():
+        raise FileNotFoundError(f"Skill '{skill_name}' has no SKILL.md file in {skill_dir}")
+
+    try:
+        with open(skill_file, encoding="utf-8") as f:
+            content = f.read()
+        return content
+    except Exception as e:
+        logger.error(f"Failed to load skill {skill_name}: {e}")
+        raise OSError(f"Error loading skill '{skill_name}': {e}") from e

python/packages/kagent-skills/src/kagent/skills/discovery.py

@@ -135,10 +135,6 @@ async def execute_command(
         env["PATH"] = f"{bash_venv_bin}:{env.get('PATH', '')}"
         env["VIRTUAL_ENV"] = bash_venv_path
 
-    logger.warning(f"path modified: {env['PATH']}")
-    logger.warning(f"Set virtual env to: {env.get('VIRTUAL_ENV')}")
-    logger.warning(f"Set pythonpath to: {env.get('PYTHONPATH')}")
-
     sandboxed_command = f'srt "{command}"'
 
     try: