Python: [Bug]: AnthropicClient TypeError: AsyncMessages.create() got an unexpected keyword argument 'allow_multiple_tool_calls'

[leelakarthik]

Description

when indiviual agent is run its working fine, but not with the orchestrator (handoff). The code sample for anthropic_basic works fine but when create two basic agent and add in orchestrator issue occurs

Code Sample

async for event in workflow.run_stream(user_input):
        # print("event:", event)
        if isinstance(event, RequestInfoEvent):
            pending_requests.append(event)

Error Messages / Stack Traces

Traceback (most recent call last):
  File "/Users/karthik/Code bases/maf_ast_agents zip/Anthropic-Agent/main.py", line 109, in <module>
    cli()
    ~~~^^
  File "/Users/karthik/Code bases/maf_ast_agents zip/Anthropic-Agent/main.py", line 105, in cli
    asyncio.run(main())
    ~~~~~~~~~~~^^^^^^^^
  File "/opt/homebrew/Cellar/python@3.13/3.13.11/Frameworks/Python.framework/Versions/3.13/lib/python3.13/asyncio/runners.py", line 195, in run
    return runner.run(main)
           ~~~~~~~~~~^^^^^^
  File "/opt/homebrew/Cellar/python@3.13/3.13.11/Frameworks/Python.framework/Versions/3.13/lib/python3.13/asyncio/runners.py", line 118, in run
    return self._loop.run_until_complete(task)
           ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^
  File "/opt/homebrew/Cellar/python@3.13/3.13.11/Frameworks/Python.framework/Versions/3.13/lib/python3.13/asyncio/base_events.py", line 725, in run_until_complete
    return future.result()
           ~~~~~~~~~~~~~^^
  File "/Users/karthik/Code bases/maf_ast_agents zip/Anthropic-Agent/main.py", line 97, in main
    await run_interactive_session(
    ...<2 lines>...
    )
  File "/Users/karthik/Code bases/maf_ast_agents zip/Anthropic-Agent/workflow.py", line 133, in run_interactive_session
    async for event in workflow.run_stream(user_input):
    ...<2 lines>...
            pending_requests.append(event)
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_workflows/_workflow.py", line 533, in run_stream
    async for event in self._run_workflow_with_tracing(
    ...<7 lines>...
        yield event
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_workflows/_workflow.py", line 343, in _run_workflow_with_tracing
    await initial_executor_fn()
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_workflows/_workflow.py", line 427, in _execute_with_message_or_checkpoint
    await executor.execute(
    ...<6 lines>...
    )
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_workflows/_executor.py", line 277, in execute
    await handler(message, context)
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_workflows/_executor.py", line 567, in wrapper
    return await func(self, message, ctx)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_workflows/_agent_executor.py", line 157, in from_str
    await self._run_agent_and_emit(ctx)
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_workflows/_handoff.py", line 386, in _run_agent_and_emit
    response = await self._run_agent_streaming(cast(WorkflowContext, ctx))
               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_workflows/_agent_executor.py", line 366, in _run_agent_streaming
    async for update in self._agent.run_stream(
    ...<8 lines>...
            user_input_requests.extend(update.user_input_requests)
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/observability.py", line 1411, in trace_run_streaming
    async for streaming_agent_response in run_streaming_func(self, messages=messages, thread=thread, **kwargs):
        yield streaming_agent_response
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_agents.py", line 982, in run_stream
    async for update in self.chat_client.get_streaming_response(
    ...<18 lines>...
        )
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_tools.py", line 2120, in streaming_function_invocation_wrapper
    async for update in func(self, messages=prepped_messages, options=options, **filtered_kwargs):
        all_updates.append(update)
        yield update
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/observability.py", line 1163, in trace_get_streaming_response
    async for update in func(self, messages=messages, options=options, **kwargs):
        yield update
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_middleware.py", line 1432, in _stream_generator
    async for update in original_get_streaming_response(
    ...<5 lines>...
        yield update
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework/_clients.py", line 362, in get_streaming_response
    async for update in self._inner_get_streaming_response(
    ...<4 lines>...
        yield update
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/agent_framework_anthropic/_chat_client.py", line 369, in _inner_get_streaming_response
    async for chunk in await self.anthropic_client.beta.messages.create(**run_options, stream=True):
                             ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/Users/karthik/Code bases/maf_ast_agents zip/.venv/lib/python3.13/site-packages/anthropic/_utils/_utils.py", line 282, in wrapper
    return func(*args, **kwargs)
TypeError: AsyncMessages.create() got an unexpected keyword argument 'allow_multiple_tool_calls'

Package Versions

Microsoft Agent Framework (pre-release) agent-framework[all]>=1.0.0b260116 # Anthropic SDK with Foundry support anthropic>=0.76.0

Python Version

3.13

Additional Context

not been able to fix the issue

[eavanvalkenburg]

@mooneva this is similar to what you just fixed for agui,but I guess in this case the workflow executors set these values, I do wonder why since the default behavior is to allow multiple and I can't think of a reason to not do that... Also @TaoChenOSU

[moonbox3]

We use the agents as they are passed into the workflow builder. We're not setting anything on the user's behalf. @leelakarthik can you share a bit more code, please, around how you're setting up the agent/chat client? Thanks.

[leelakarthik]

from agent_framework import FunctionApprovalRequestContent, HandoffAgentUserRequest, HandoffBuilder, RequestInfoEvent, WorkflowOutputEvent
from agent_framework_anthropic import AnthropicClient
from anthropic import AsyncAnthropicFoundry


client = AnthropicClient(
            anthropic_client=AsyncAnthropicFoundry(),
            model_id="claude-opus-4-5",
        )
triage = client.as_agent(
        name="triage_agent",
        description="Routes user requests to the appropriate specialist agent",
        instructions=TRIAGE_INSTRUCTIONS,
    )
analyzer = client.as_agent(
        name="email analyzer",
        description="Analyzes Email content and provides insights.",
        instructions=ANALYZER_INSTRUCTIONS,
    )

categorizer = client.as_agent(
        name="email categorizer",
        description="Analyzes Email content and categorizes it.",
        instructions=CATEGORIZER_INSTRUCTIONS,
    )

workflow = HandoffBuilder(
    name="codebase_analysis_workflow",
    participants=[triage, analyzer, categorizer],
).with_start_agent(triage)
.add_handoff(triage, [analyzer, categorizer])
.add_handoff(analyzer, [categorizer, triage])
.add_handoff(categorizer, [analyzer, triage])
.with_termination_condition(
        lambda conversation: (
            len(conversation) > 0
            and any(
                word in conversation[-1].text.lower()
                for word in ["goodbye", "thanks, done", "that's all", "exit"]
            )
        )
    )
.build()
user_input = input("You: ").strip()
pending_requests: list[RequestInfoEvent] = []

async for event in workflow.run_stream(user_input):
    if isinstance(event, RequestInfoEvent):
        pending_requests.append(event)


while pending_requests:
    responses = {}

    for request in pending_requests:
        if isinstance(request.data, HandoffAgentUserRequest):
            print()
            for msg in request.data.agent_response.messages[-3:]:
                if msg.text:
                    print(f"{msg.author_name}: {msg.text}")
            print()

            # Get user input
            user_input = input("You: ").strip()
            if not user_input:
                user_input = "continue"

            # Check for exit
            if user_input.lower() in ["exit", "goodbye", "quit"]:
                responses[request.request_id] = HandoffAgentUserRequest.create_response(
                    "goodbye"
                )
            else:
                responses[request.request_id] = HandoffAgentUserRequest.create_response(
                    user_input
                )

        elif isinstance(request.data, FunctionApprovalRequestContent):
            func_call = request.data.function_call
            args = func_call.parse_arguments() or {}

            print(f"\n[Tool Request] {func_call.name}")
            print(f"  Arguments: {args}")
            approval = input("  Approve? (y/n): ").strip().lower()

            responses[request.request_id] = request.data.create_response(
                approved=(approval == "y")
            )
    pending_requests = []
    async for event in workflow.send_responses_streaming(responses):
        if isinstance(event, RequestInfoEvent):
            pending_requests.append(event)
        elif isinstance(event, WorkflowOutputEvent):
            print("\n[Session ended]")
            return

print("\n[Session completed]")

[leelakarthik]

any update on this one sir