mirror of
https://github.com/langgenius/dify.git
synced 2026-06-08 09:27:39 +08:00
246c1d74a4
* ``AgentBackendRunRequestBuilder.build_for_agent_app`` + the ``AgentBackendAgentAppRunInput`` DTO: the app-shaped layer graph (agent soul system prompt → user message → execution context → history → llm → optional plugin tools → optional output), purpose=agent_app, on_exit=suspend. No workflow-node-job / previous-node prompt. * ``AgentAppRuntimeRequestBuilder`` maps an Agent Soul snapshot + conversation turn into a CreateRunRequest: plugin-daemon plugin_id/provider normalization, credential fetch + scalar normalization, Dify plugin tools (reuses WorkflowAgentPluginToolsBuilder), conversation-scoped execution_context with invoke_from=agent_app, and the prior session_snapshot for multi-turn. Tests: 5 builder/DTO cases + reuses the conversation session store; 40 passing across agent_backend + agent_app suites. ruff + pyrefly clean. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
83 lines
2.9 KiB
Python
83 lines
2.9 KiB
Python
"""API-side integration boundary for the Dify Agent backend.
|
|
|
|
Public wire DTOs come from ``dify_agent.protocol``. This package only contains
|
|
API adapters: request building from Dify product concepts, a thin client wrapper,
|
|
event adaptation for future workflow integration, and deterministic fakes.
|
|
"""
|
|
|
|
from clients.agent_backend.client import AgentBackendRunClient, DifyAgentBackendRunClient
|
|
from clients.agent_backend.errors import (
|
|
AgentBackendError,
|
|
AgentBackendHTTPError,
|
|
AgentBackendRequestBuildError,
|
|
AgentBackendRunFailedError,
|
|
AgentBackendStreamError,
|
|
AgentBackendTransportError,
|
|
AgentBackendValidationError,
|
|
)
|
|
from clients.agent_backend.event_adapter import (
|
|
AgentBackendInternalEvent,
|
|
AgentBackendInternalEventType,
|
|
AgentBackendRunCancelledInternalEvent,
|
|
AgentBackendRunEventAdapter,
|
|
AgentBackendRunFailedInternalEvent,
|
|
AgentBackendRunPausedInternalEvent,
|
|
AgentBackendRunStartedInternalEvent,
|
|
AgentBackendRunSucceededInternalEvent,
|
|
AgentBackendStreamInternalEvent,
|
|
)
|
|
from clients.agent_backend.factory import create_agent_backend_run_client
|
|
from clients.agent_backend.fake_client import FakeAgentBackendRunClient, FakeAgentBackendScenario
|
|
from clients.agent_backend.request_builder import (
|
|
AGENT_SOUL_PROMPT_LAYER_ID,
|
|
DIFY_EXECUTION_CONTEXT_LAYER_ID,
|
|
DIFY_PLUGIN_TOOLS_LAYER_ID,
|
|
WORKFLOW_NODE_JOB_PROMPT_LAYER_ID,
|
|
WORKFLOW_USER_PROMPT_LAYER_ID,
|
|
AgentBackendAgentAppRunInput,
|
|
AgentBackendModelConfig,
|
|
AgentBackendOutputConfig,
|
|
AgentBackendRunRequestBuilder,
|
|
AgentBackendWorkflowNodeRunInput,
|
|
CleanupLayerSpec,
|
|
extract_cleanup_layer_specs,
|
|
redact_for_agent_backend_log,
|
|
)
|
|
|
|
__all__ = [
|
|
"AGENT_SOUL_PROMPT_LAYER_ID",
|
|
"DIFY_EXECUTION_CONTEXT_LAYER_ID",
|
|
"DIFY_PLUGIN_TOOLS_LAYER_ID",
|
|
"WORKFLOW_NODE_JOB_PROMPT_LAYER_ID",
|
|
"WORKFLOW_USER_PROMPT_LAYER_ID",
|
|
"AgentBackendAgentAppRunInput",
|
|
"AgentBackendError",
|
|
"AgentBackendHTTPError",
|
|
"AgentBackendInternalEvent",
|
|
"AgentBackendInternalEventType",
|
|
"AgentBackendModelConfig",
|
|
"AgentBackendOutputConfig",
|
|
"AgentBackendRequestBuildError",
|
|
"AgentBackendRunCancelledInternalEvent",
|
|
"AgentBackendRunClient",
|
|
"AgentBackendRunEventAdapter",
|
|
"AgentBackendRunFailedError",
|
|
"AgentBackendRunFailedInternalEvent",
|
|
"AgentBackendRunPausedInternalEvent",
|
|
"AgentBackendRunRequestBuilder",
|
|
"AgentBackendRunStartedInternalEvent",
|
|
"AgentBackendRunSucceededInternalEvent",
|
|
"AgentBackendStreamError",
|
|
"AgentBackendStreamInternalEvent",
|
|
"AgentBackendTransportError",
|
|
"AgentBackendValidationError",
|
|
"AgentBackendWorkflowNodeRunInput",
|
|
"CleanupLayerSpec",
|
|
"DifyAgentBackendRunClient",
|
|
"FakeAgentBackendRunClient",
|
|
"FakeAgentBackendScenario",
|
|
"create_agent_backend_run_client",
|
|
"extract_cleanup_layer_specs",
|
|
"redact_for_agent_backend_log",
|
|
]
|