Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 1 addition & 6 deletions agents/chat/src/chat/agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,7 @@
from textwrap import dedent
from typing import Annotated

from a2a.types import (
AgentSkill,
Message,
)
from a2a.types import AgentSkill, Message
from agentstack_sdk.a2a.extensions import (
AgentDetail,
AgentDetailContributor,
Expand All @@ -24,8 +21,6 @@
LLMServiceExtensionSpec,
TrajectoryExtensionServer,
TrajectoryExtensionSpec,
)
from agentstack_sdk.a2a.extensions.services.platform import (
PlatformApiExtensionServer,
PlatformApiExtensionSpec,
)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,7 @@
from langchain_core.tools import BaseTool
from langchain_openai import ChatOpenAI
from pydantic import SecretStr
from a2a.types import Role
from a2a.types import Message as A2AMessage
from a2a.types import Role, Message as A2AMessage
from langchain.messages import AIMessage, HumanMessage
from agentstack_sdk.a2a.extensions import LLMFulfillment

Expand Down
4 changes: 1 addition & 3 deletions agents/form/src/form/agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import a2a.types
import agentstack_sdk.a2a.extensions
from a2a.types import Message
from agentstack_sdk.a2a.extensions.common.form import (
from agentstack_sdk.a2a.extensions import (
CheckboxField,
DateField,
FileField,
Expand All @@ -18,8 +18,6 @@
MultiSelectField,
OptionItem,
TextField,
)
from agentstack_sdk.a2a.extensions.services.form import (
FormServiceExtensionServer,
FormServiceExtensionSpec,
)
Expand Down
10 changes: 8 additions & 2 deletions agents/rag/src/rag/agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,9 @@
LLMServiceExtensionSpec,
TrajectoryExtensionServer,
TrajectoryExtensionSpec,
PlatformApiExtensionServer,
PlatformApiExtensionSpec,
)
from agentstack_sdk.a2a.extensions.services.platform import PlatformApiExtensionServer, PlatformApiExtensionSpec
from agentstack_sdk.a2a.types import AgentArtifact, AgentMessage
from agentstack_sdk.server import Server
from agentstack_sdk.server.context import RunContext
Expand All @@ -41,7 +42,12 @@
from rag.helpers.citations import extract_citations
from rag.helpers.event_binder import EventBinder
from rag.helpers.trajectory import ToolCallTrajectoryEvent
from rag.helpers.vectore_store import CreateVectorStoreEvent, EmbeddingFunction, create_vector_store, embed_all_files
from rag.helpers.vectore_store import (
CreateVectorStoreEvent,
EmbeddingFunction,
create_vector_store,
embed_all_files,
)
from rag.tools.files.file_creator import FileCreatorTool, FileCreatorToolOutput
from rag.tools.files.file_reader import create_file_reader_tool_class
from rag.tools.files.utils import extract_files, to_framework_message
Expand Down
2 changes: 1 addition & 1 deletion agents/rag/src/rag/helpers/trajectory.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
from typing import Any, Literal
from beeai_framework.errors import FrameworkError
from beeai_framework.tools import ToolOutput
from agentstack_sdk.a2a.extensions.ui.trajectory import TrajectoryExtensionServer
from agentstack_sdk.a2a.extensions import TrajectoryExtensionServer
from pydantic import BaseModel, Field, InstanceOf, field_serializer


Expand Down
10 changes: 2 additions & 8 deletions agents/rag/src/rag/helpers/vectore_store.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,16 +12,10 @@
from openai.types import CreateEmbeddingResponse

from agentstack_sdk.a2a.extensions import TrajectoryExtensionServer
from agentstack_sdk.platform import File, VectorStore
from agentstack_sdk.platform.vector_store import VectorStoreItem
from agentstack_sdk.platform import File, VectorStore, VectorStoreItem
from langchain_text_splitters import RecursiveCharacterTextSplitter
from rag.helpers.trajectory import TrajectoryEvent
from tenacity import (
AsyncRetrying,
retry_if_exception_type,
stop_after_delay,
wait_fixed,
)
from tenacity import AsyncRetrying, retry_if_exception_type, stop_after_delay, wait_fixed


class FileExtractionEvent(TrajectoryEvent):
Expand Down
6 changes: 1 addition & 5 deletions agents/rag/src/rag/tools/files/file_reader.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,11 +7,7 @@

from agentstack_sdk.platform import File
from beeai_framework.emitter import Emitter
from beeai_framework.tools import (
JSONToolOutput,
Tool,
ToolRunOptions,
)
from beeai_framework.tools import JSONToolOutput, Tool, ToolRunOptions
from pydantic import BaseModel, Field, create_model

from rag.tools.files.utils import format_size
Expand Down
9 changes: 2 additions & 7 deletions agents/rag/src/rag/tools/general/act.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,15 +6,10 @@
import typing
from typing import Literal

from beeai_framework.agents.requirement import (
RequirementAgent,
RequirementAgentRunState,
)
from beeai_framework.agents.requirement import RequirementAgent, RequirementAgentRunState
from beeai_framework.agents.requirement.events import RequirementAgentStartEvent
from beeai_framework.agents.requirement.requirements import Requirement, Rule
from beeai_framework.agents.requirement.requirements.requirement import (
run_with_context,
)
from beeai_framework.agents.requirement.requirements.requirement import run_with_context
from beeai_framework.context import RunContext
from beeai_framework.emitter import Emitter, EventMeta
from beeai_framework.tools import (
Expand Down
12 changes: 2 additions & 10 deletions agents/rag/src/rag/tools/general/clarification.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,20 +3,12 @@

from __future__ import annotations

from beeai_framework.agents.requirement import (
RequirementAgent,
RequirementAgentRunState,
)
from beeai_framework.agents.requirement import RequirementAgent, RequirementAgentRunState
from beeai_framework.agents.requirement.events import RequirementAgentStartEvent
from beeai_framework.backend import AssistantMessage
from beeai_framework.context import RunContext
from beeai_framework.emitter import Emitter, EventMeta
from beeai_framework.tools import (
StringToolOutput,
Tool,
ToolInputValidationError,
ToolRunOptions,
)
from beeai_framework.tools import StringToolOutput, Tool, ToolInputValidationError, ToolRunOptions
from pydantic import BaseModel, Field


Expand Down
2 changes: 1 addition & 1 deletion apps/agentstack-sdk-py/examples/agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
import uvicorn

import agentstack_sdk.a2a.extensions
from agentstack_sdk.a2a.extensions.services.llm import LLMServiceExtensionServer
from agentstack_sdk.a2a.extensions import LLMServiceExtensionServer

agent_detail_extension_spec = agentstack_sdk.a2a.extensions.AgentDetailExtensionSpec(
params=agentstack_sdk.a2a.extensions.AgentDetail(
Expand Down
6 changes: 1 addition & 5 deletions apps/agentstack-sdk-py/examples/artifacts.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,17 +11,13 @@
from a2a.utils.message import get_message_text
from beeai_framework.adapters.agentstack.backend.chat import AgentStackChatModel
from beeai_framework.agents.requirement import RequirementAgent
from beeai_framework.agents.requirement.requirements.conditional import (
ConditionalRequirement,
)
from beeai_framework.agents.requirement.requirements.conditional import ConditionalRequirement
from beeai_framework.backend import AssistantMessage, UserMessage
from beeai_framework.tools.think import ThinkTool

from agentstack_sdk.a2a.extensions import (
LLMServiceExtensionServer,
LLMServiceExtensionSpec,
)
from agentstack_sdk.a2a.extensions.ui.canvas import (
CanvasEditRequest,
CanvasExtensionServer,
CanvasExtensionSpec,
Expand Down
3 changes: 2 additions & 1 deletion apps/agentstack-sdk-py/examples/canvas_ui_code_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,9 @@
ErrorExtensionParams,
ErrorExtensionServer,
ErrorExtensionSpec,
CanvasExtensionServer,
CanvasExtensionSpec,
)
from agentstack_sdk.a2a.extensions.ui.canvas import CanvasExtensionServer, CanvasExtensionSpec
from agentstack_sdk.a2a.types import AgentArtifact, AgentMessage
from agentstack_sdk.server import Server
from agentstack_sdk.server.context import RunContext
Expand Down
2 changes: 1 addition & 1 deletion apps/agentstack-sdk-py/examples/canvas_ui_test_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@

from a2a.types import Message, TextPart

from agentstack_sdk.a2a.extensions.ui.canvas import CanvasExtensionServer, CanvasExtensionSpec
from agentstack_sdk.a2a.extensions import CanvasExtensionServer, CanvasExtensionSpec
from agentstack_sdk.a2a.types import AgentArtifact, AgentMessage
from agentstack_sdk.server import Server
from agentstack_sdk.server.context import RunContext
Expand Down
6 changes: 1 addition & 5 deletions apps/agentstack-sdk-py/examples/citation_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,7 @@

from a2a.types import Message

from agentstack_sdk.a2a.extensions import (
Citation,
CitationExtensionServer,
CitationExtensionSpec,
)
from agentstack_sdk.a2a.extensions import Citation, CitationExtensionServer, CitationExtensionSpec
from agentstack_sdk.a2a.types import AgentMessage
from agentstack_sdk.server import Server
from agentstack_sdk.server.context import RunContext
Expand Down
6 changes: 1 addition & 5 deletions apps/agentstack-sdk-py/examples/citation_agent_artifact.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,11 +8,7 @@

from a2a.types import Message, TextPart

from agentstack_sdk.a2a.extensions import (
Citation,
CitationExtensionServer,
CitationExtensionSpec,
)
from agentstack_sdk.a2a.extensions import Citation, CitationExtensionServer, CitationExtensionSpec
from agentstack_sdk.a2a.types import AgentArtifact
from agentstack_sdk.server import Server
from agentstack_sdk.server.context import RunContext
Expand Down
2 changes: 1 addition & 1 deletion apps/agentstack-sdk-py/examples/connector_management.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
import asyncio
import logging

from agentstack_sdk.platform.connector import Connector, ConnectorState
from agentstack_sdk.platform import Connector, ConnectorState

logger = logging.getLogger(__name__)
logging.basicConfig(level=logging.INFO)
Expand Down
8 changes: 6 additions & 2 deletions apps/agentstack-sdk-py/examples/connectors_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,12 @@
from a2a.types import Message
from mcp import ClientSession

from agentstack_sdk.a2a.extensions.services.mcp import MCPServiceExtensionServer, MCPServiceExtensionSpec
from agentstack_sdk.a2a.extensions.services.platform import PlatformApiExtensionServer, PlatformApiExtensionSpec
from agentstack_sdk.a2a.extensions import (
MCPServiceExtensionServer,
MCPServiceExtensionSpec,
PlatformApiExtensionServer,
PlatformApiExtensionSpec,
)
from agentstack_sdk.a2a.types import RunYield
from agentstack_sdk.server import Server
from agentstack_sdk.server.context import RunContext
Expand Down
4 changes: 2 additions & 2 deletions apps/agentstack-sdk-py/examples/connectors_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,8 @@
from pydantic import HttpUrl

import agentstack_sdk.a2a.extensions
from agentstack_sdk.a2a.extensions.services.platform import PlatformApiExtensionClient
from agentstack_sdk.platform.client import use_platform_client
from agentstack_sdk.a2a.extensions import PlatformApiExtensionClient
from agentstack_sdk.platform import use_platform_client
from agentstack_sdk.platform.context import Context, ContextPermissions, Permissions


Expand Down
8 changes: 5 additions & 3 deletions apps/agentstack-sdk-py/examples/dependencies.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,12 +8,14 @@

from a2a.types import Message

from agentstack_sdk.a2a.extensions import LLMServiceExtensionServer, LLMServiceExtensionSpec
from agentstack_sdk.a2a.extensions.services.platform import (
from agentstack_sdk.a2a.extensions import (
LLMServiceExtensionServer,
LLMServiceExtensionSpec,
PlatformApiExtensionServer,
PlatformApiExtensionSpec,
TrajectoryExtensionServer,
TrajectoryExtensionSpec,
)
from agentstack_sdk.a2a.extensions.ui.trajectory import TrajectoryExtensionServer, TrajectoryExtensionSpec
from agentstack_sdk.a2a.types import AuthRequired, RunYield
from agentstack_sdk.platform import File
from agentstack_sdk.server import Server
Expand Down
2 changes: 1 addition & 1 deletion apps/agentstack-sdk-py/examples/error_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@

from a2a.types import Message

from agentstack_sdk.a2a.extensions.ui.error import (
from agentstack_sdk.a2a.extensions import (
ErrorExtensionParams,
ErrorExtensionServer,
ErrorExtensionSpec,
Expand Down
5 changes: 3 additions & 2 deletions apps/agentstack-sdk-py/examples/form_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,9 @@
from a2a.types import Message
from pydantic import BaseModel

from agentstack_sdk.a2a.extensions.common.form import FormRender, TextField
from agentstack_sdk.a2a.extensions.services.form import (
from agentstack_sdk.a2a.extensions import (
FormRender,
TextField,
FormServiceExtensionServer,
FormServiceExtensionSpec,
)
Expand Down
5 changes: 3 additions & 2 deletions apps/agentstack-sdk-py/examples/form_request_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
from a2a.types import Message
from pydantic import BaseModel

from agentstack_sdk.a2a.extensions.common.form import (
from agentstack_sdk.a2a.extensions import (
CheckboxField,
DateField,
FileField,
Expand All @@ -18,8 +18,9 @@
OptionItem,
SingleSelectField,
TextField,
FormRequestExtensionServer,
FormRequestExtensionSpec,
)
from agentstack_sdk.a2a.extensions.ui.form_request import FormRequestExtensionServer, FormRequestExtensionSpec
from agentstack_sdk.server import Server

server = Server()
Expand Down
2 changes: 1 addition & 1 deletion apps/agentstack-sdk-py/examples/github_mcp_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
from a2a.types import Message
from mcp import ClientSession

from agentstack_sdk.a2a.extensions.services.mcp import MCPServiceExtensionServer, MCPServiceExtensionSpec
from agentstack_sdk.a2a.extensions import MCPServiceExtensionServer, MCPServiceExtensionSpec
from agentstack_sdk.a2a.types import RunYield
from agentstack_sdk.server import Server

Expand Down
5 changes: 1 addition & 4 deletions apps/agentstack-sdk-py/examples/history_framework.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,10 +14,7 @@
from beeai_framework.backend import AssistantMessage, UserMessage
from beeai_framework.tools.think import ThinkTool

from agentstack_sdk.a2a.extensions import (
LLMServiceExtensionServer,
LLMServiceExtensionSpec,
)
from agentstack_sdk.a2a.extensions import LLMServiceExtensionServer, LLMServiceExtensionSpec
from agentstack_sdk.a2a.types import AgentMessage
from agentstack_sdk.server import Server
from agentstack_sdk.server.context import RunContext
Expand Down
8 changes: 5 additions & 3 deletions apps/agentstack-sdk-py/examples/mcp_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,11 @@
from a2a.types import Message
from mcp import ClientSession

from agentstack_sdk.a2a.extensions.auth.oauth import OAuthExtensionServer, OAuthExtensionSpec
from agentstack_sdk.a2a.extensions.services.mcp import MCPServiceExtensionServer, MCPServiceExtensionSpec
from agentstack_sdk.a2a.extensions.tools.call import (
from agentstack_sdk.a2a.extensions import (
OAuthExtensionServer,
OAuthExtensionSpec,
MCPServiceExtensionServer,
MCPServiceExtensionSpec,
ToolCallExtensionParams,
ToolCallExtensionServer,
ToolCallExtensionSpec,
Expand Down
2 changes: 1 addition & 1 deletion apps/agentstack-sdk-py/examples/mcp_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
from pydantic import AnyUrl

import agentstack_sdk.a2a.extensions
from agentstack_sdk.a2a.extensions.tools.call import ToolCallResponse
from agentstack_sdk.a2a.extensions import ToolCallResponse


class OAuthHandler:
Expand Down
10 changes: 4 additions & 6 deletions apps/agentstack-sdk-py/examples/oauth.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,21 +11,19 @@
from a2a.utils.message import get_message_text
from beeai_framework.adapters.agentstack.backend.chat import AgentStackChatModel
from beeai_framework.agents.requirement import RequirementAgent
from beeai_framework.agents.requirement.requirements.conditional import (
ConditionalRequirement,
)
from beeai_framework.agents.requirement.requirements.conditional import ConditionalRequirement
from beeai_framework.backend import AssistantMessage, UserMessage
from beeai_framework.backend.types import ChatModelParameters
from beeai_framework.tools.mcp import MCPTool
from beeai_framework.tools.think import ThinkTool
from mcp import ClientSession
from mcp.client.streamable_http import streamablehttp_client # pyrefly: ignore [deprecated] -- TODO: upgrade
from mcp.client.streamable_http import (
streamablehttp_client # pyrefly: ignore [deprecated] -- TODO: upgrade,
)

from agentstack_sdk.a2a.extensions import (
LLMServiceExtensionServer,
LLMServiceExtensionSpec,
)
from agentstack_sdk.a2a.extensions.auth.oauth import (
OAuthExtensionServer,
OAuthExtensionSpec,
)
Expand Down
Loading
Loading