Skip to content
Open
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
29 changes: 24 additions & 5 deletions python/packages/core/agent_framework/_workflows/_workflow.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,11 +11,11 @@
import types
import uuid
from collections.abc import AsyncIterable, Awaitable, Callable, Sequence
from typing import Any, Literal, overload
from typing import TYPE_CHECKING, Any, Literal, overload

from .._sessions import BaseContextProvider
from .._types import ResponseStream
from ..observability import OtelAttr, capture_exception, create_workflow_span
from ._agent import WorkflowAgent
from ._checkpoint import CheckpointStorage
from ._const import DEFAULT_MAX_ITERATIONS, WORKFLOW_RUN_KWARGS_KEY
from ._edge import (
Expand All @@ -35,6 +35,9 @@
from ._state import State
from ._typing_utils import is_instance_of, try_coerce_to_type

if TYPE_CHECKING:
from ._agent import WorkflowAgent

logger = logging.getLogger(__name__)


Expand Down Expand Up @@ -854,7 +857,14 @@ def output_types(self) -> list[type[Any] | types.UnionType]:

return list(output_types)

def as_agent(self, name: str | None = None) -> WorkflowAgent:
def as_agent(
self,
name: str | None = None,
*,
description: str | None = None,
context_providers: Sequence[BaseContextProvider] | None = None,
**kwargs: Any,
) -> WorkflowAgent:
"""Create a WorkflowAgent that wraps this workflow.

The returned agent converts standard agent inputs (strings, Message, or lists of these)
Expand All @@ -868,7 +878,10 @@ def as_agent(self, name: str | None = None) -> WorkflowAgent:
initialization will fail with a ValueError.

Args:
name: Optional name for the agent. If None, a default name will be generated.
name: Optional name for the agent. Defaults to workflow name.
description: Optional description of the agent. Defaults to workflow description.
context_providers: Optional sequence of context providers for the agent.
**kwargs: Additional keyword arguments passed to BaseAgent.

Returns:
A WorkflowAgent instance that wraps this workflow.
Expand All @@ -879,4 +892,10 @@ def as_agent(self, name: str | None = None) -> WorkflowAgent:
# Import here to avoid circular imports
from ._agent import WorkflowAgent

return WorkflowAgent(workflow=self, name=name)
return WorkflowAgent(
workflow=self,
name=name if name is not None else self.name,
description=description if description is not None else self.description,
context_providers=context_providers,
**kwargs,
)
31 changes: 31 additions & 0 deletions python/packages/core/tests/workflow/test_workflow_agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -312,6 +312,37 @@ def test_workflow_as_agent_method(self) -> None:
assert isinstance(agent_no_name, WorkflowAgent)
assert agent_no_name.workflow is workflow

def test_workflow_as_agent_with_description_and_context_providers(self) -> None:
"""Test that Workflow.as_agent() forwards description and context_providers."""
executor = SimpleExecutor(id="executor1", response_text="Response")
workflow = WorkflowBuilder(start_executor=executor).build()

history_provider = InMemoryHistoryProvider()
agent = workflow.as_agent(
name="MyAgent",
description="A test agent",
context_providers=[history_provider],
)

assert isinstance(agent, WorkflowAgent)
assert agent.name == "MyAgent"
assert agent.description == "A test agent"
assert history_provider in agent.context_providers

def test_workflow_as_agent_defaults_name_and_description_from_workflow(self) -> None:
"""Test that as_agent() defaults name and description to the workflow's own values."""
executor = SimpleExecutor(id="executor1", response_text="Response")
workflow = WorkflowBuilder(
start_executor=executor,
name="my-workflow",
description="Workflow description",
).build()

agent = workflow.as_agent()

assert agent.name == "my-workflow"
assert agent.description == "Workflow description"

def test_workflow_as_agent_cannot_handle_agent_inputs(self) -> None:
"""Test that Workflow.as_agent() raises an error if the start executor cannot handle agent inputs."""

Expand Down
Loading