Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
(base) daniel.miller@SCMC4KVFJ06LL tutorials % ./run_all_async_tests.sh
Running All Async Tutorial Tests
β Prerequisites check passed
Testing: 00_sync/000_hello_acp
π Starting 000_hello_acp agent...
β 000_hello_acp agent started (PID: 92063, logs: /tmp/agentex-000_hello_acp.log)
β³ Waiting for 000_hello_acp agent to be ready...
β 000_hello_acp agent is ready
π§ͺ Running tests for 000_hello_acp...
========================================================== test session starts ==========================================================
platform darwin -- Python 3.13.5, pytest-8.4.2, pluggy-1.6.0 -- /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials/00_sync/000_hello_acp/.venv/bin/python
cachedir: .pytest_cache
rootdir: /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials
configfile: pytest.ini
plugins: asyncio-1.2.0, anyio-4.11.0, xdist-3.8.0, ddtrace-3.18.0
asyncio: mode=Mode.STRICT, debug=False, asyncio_default_fixture_loop_scope=None, asyncio_default_test_loop_scope=function
collected 2 items
tests/test_agent.py::TestNonStreamingMessages::test_send_simple_message PASSED
tests/test_agent.py::TestStreamingMessages::test_stream_simple_message PASSED
=========================================================== 2 passed in 0.21s ===========================================================
β Tests passed for 000_hello_acp
β PASSED: 00_sync/000_hello_acp
π Stopping 000_hello_acp agent...
Stopping 000_hello_acp agent (PID: 92063)
β 000_hello_acp agent stopped
Logs available at: /tmp/agentex-000_hello_acp.log
Testing: 00_sync/010_multiturn
π Starting 010_multiturn agent...
β 010_multiturn agent started (PID: 92092, logs: /tmp/agentex-010_multiturn.log)
β³ Waiting for 010_multiturn agent to be ready...
β 010_multiturn agent is ready
π§ͺ Running tests for 010_multiturn...
========================================================== test session starts ==========================================================
platform darwin -- Python 3.13.5, pytest-8.4.2, pluggy-1.6.0 -- /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials/00_sync/010_multiturn/.venv/bin/python
cachedir: .pytest_cache
rootdir: /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials
configfile: pytest.ini
plugins: asyncio-1.2.0, anyio-4.11.0, ddtrace-3.18.0
asyncio: mode=Mode.STRICT, debug=False, asyncio_default_fixture_loop_scope=None, asyncio_default_test_loop_scope=function
collected 2 items
tests/test_agent.py::TestNonStreamingMessages::test_send_message PASSED
tests/test_agent.py::TestStreamingMessages::test_stream_message PASSED
========================================================== 2 passed in 30.75s ===========================================================
β Tests passed for 010_multiturn
β PASSED: 00_sync/010_multiturn
π Stopping 010_multiturn agent...
Stopping 010_multiturn agent (PID: 92092)
β 010_multiturn agent stopped
Logs available at: /tmp/agentex-010_multiturn.log
Testing: 00_sync/020_streaming
π Starting 020_streaming agent...
β 020_streaming agent started (PID: 92152, logs: /tmp/agentex-020_streaming.log)
β³ Waiting for 020_streaming agent to be ready...
β 020_streaming agent is ready
π§ͺ Running tests for 020_streaming...
========================================================== test session starts ==========================================================
platform darwin -- Python 3.13.5, pytest-8.4.2, pluggy-1.6.0 -- /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials/00_sync/020_streaming/.venv/bin/python
cachedir: .pytest_cache
rootdir: /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials
configfile: pytest.ini
plugins: asyncio-1.2.0, anyio-4.11.0, ddtrace-3.18.0
asyncio: mode=Mode.STRICT, debug=False, asyncio_default_fixture_loop_scope=None, asyncio_default_test_loop_scope=function
collected 2 items
tests/test_agent.py::TestNonStreamingMessages::test_send_message PASSED
tests/test_agent.py::TestStreamingMessages::test_send_stream_message PASSED
========================================================== 2 passed in 33.14s ===========================================================
β Tests passed for 020_streaming
β PASSED: 00_sync/020_streaming
π Stopping 020_streaming agent...
Stopping 020_streaming agent (PID: 92152)
β 020_streaming agent stopped
Logs available at: /tmp/agentex-020_streaming.log
Testing: 10_async/10_temporal/060_open_ai_agents_sdk_hello_world
π Starting 060_open_ai_agents_sdk_hello_world agent...
β 060_open_ai_agents_sdk_hello_world agent started (PID: 92333, logs: /tmp/agentex-060_open_ai_agents_sdk_hello_world.log)
β³ Waiting for 060_open_ai_agents_sdk_hello_world agent to be ready...
β 060_open_ai_agents_sdk_hello_world agent is ready
π§ͺ Running tests for 060_open_ai_agents_sdk_hello_world...
========================================================== test session starts ==========================================================
platform darwin -- Python 3.13.5, pytest-8.4.2, pluggy-1.6.0 -- /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials/10_async/10_temporal/060_open_ai_agents_sdk_hello_world/.venv/bin/python
cachedir: .pytest_cache
rootdir: /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials
configfile: pytest.ini
plugins: asyncio-1.2.0, anyio-4.11.0, ddtrace-3.18.0
asyncio: mode=Mode.STRICT, debug=False, asyncio_default_fixture_loop_scope=None, asyncio_default_test_loop_scope=function
collected 2 items
tests/test_agent.py::TestNonStreamingEvents::test_send_event_and_poll [DEBUG 060 POLL] Sending message: 'Hello how is life?'
[DEBUG 060 POLL] Received update - Status: None, Content length: 295
[DEBUG 060 POLL] Received update - Status: IN_PROGRESS, Content length: 0
[DEBUG 060 POLL] Received update - Status: DONE, Content length: 84
[DEBUG 060 POLL] Streaming complete!
[DEBUG 060 POLL] β Successfully received haiku response!
[DEBUG 060 POLL] Final haiku:
Life flows like a stream,
With moments of peace and change,
Endless in its song.
PASSED
tests/test_agent.py::TestStreamingEvents::test_send_event_and_stream PASSED
=========================================================== 2 passed in 3.28s ===========================================================
β Tests passed for 060_open_ai_agents_sdk_hello_world
β PASSED: 10_async/10_temporal/060_open_ai_agents_sdk_hello_world
π Stopping 060_open_ai_agents_sdk_hello_world agent...
Stopping 060_open_ai_agents_sdk_hello_world agent (PID: 92333)
β 060_open_ai_agents_sdk_hello_world agent stopped
Logs available at: /tmp/agentex-060_open_ai_agents_sdk_hello_world.log
Testing: 10_async/10_temporal/070_open_ai_agents_sdk_tools
π Starting 070_open_ai_agents_sdk_tools agent...
β 070_open_ai_agents_sdk_tools agent started (PID: 92546, logs: /tmp/agentex-070_open_ai_agents_sdk_tools.log)
β³ Waiting for 070_open_ai_agents_sdk_tools agent to be ready...
β 070_open_ai_agents_sdk_tools agent is ready
π§ͺ Running tests for 070_open_ai_agents_sdk_tools...
========================================================== test session starts ==========================================================
platform darwin -- Python 3.13.5, pytest-8.4.2, pluggy-1.6.0 -- /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials/10_async/10_temporal/070_open_ai_agents_sdk_tools/.venv/bin/python
cachedir: .pytest_cache
rootdir: /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials
configfile: pytest.ini
plugins: asyncio-1.2.0, anyio-4.11.0, ddtrace-3.18.0
asyncio: mode=Mode.STRICT, debug=False, asyncio_default_fixture_loop_scope=None, asyncio_default_test_loop_scope=function
collected 2 items
tests/test_agent.py::TestNonStreamingEvents::test_send_event_and_poll [DEBUG 070 POLL] Polling for initial task creation message...
[DEBUG 070 POLL] Initial message: Hello! I've received your task. Normally you can do some state initialization here, or just pass and
[DEBUG 070 POLL] Sending message: 'What is the weather in New York City?'
[DEBUG 070 POLL] Received message - Type: text, Author: agent, Status: None
[DEBUG 070 POLL] Agent text update - Status: None, Length: 375
[DEBUG 070 POLL] Received message - Type: text, Author: user, Status: None
[DEBUG 070 POLL] Received message - Type: text, Author: agent, Status: IN_PROGRESS
[DEBUG 070 POLL] Agent text update - Status: IN_PROGRESS, Length: 0
[DEBUG 070 POLL] Received message - Type: text, Author: agent, Status: DONE
[DEBUG 070 POLL] Agent text update - Status: DONE, Length: 0
[DEBUG 070 POLL] Received message - Type: tool_request, Author: agent, Status: DONE
[DEBUG 070 POLL] β Saw tool_request - agent is calling get_weather tool
[DEBUG 070 POLL] Received message - Type: tool_response, Author: agent, Status: DONE
[DEBUG 070 POLL] β Saw tool_response - get_weather returned result
[DEBUG 070 POLL] Received message - Type: text, Author: agent, Status: IN_PROGRESS
[DEBUG 070 POLL] Agent text update - Status: IN_PROGRESS, Length: 0
[DEBUG 070 POLL] Received message - Type: text, Author: agent, Status: DONE
[DEBUG 070 POLL] Agent text update - Status: DONE, Length: 63
[DEBUG 070 POLL] β Streaming complete!
[DEBUG 070 POLL] Final response: The current temperature in New York City is 22 degrees Celsius.
PASSED
tests/test_agent.py::TestStreamingEvents::test_send_event_and_stream PASSED
=========================================================== 2 passed in 4.31s ===========================================================
β Tests passed for 070_open_ai_agents_sdk_tools
β PASSED: 10_async/10_temporal/070_open_ai_agents_sdk_tools
π Stopping 070_open_ai_agents_sdk_tools agent...
Stopping 070_open_ai_agents_sdk_tools agent (PID: 92546)
β 070_open_ai_agents_sdk_tools agent stopped
Logs available at: /tmp/agentex-070_open_ai_agents_sdk_tools.log
Testing: 10_async/10_temporal/080_open_ai_agents_sdk_human_in_the_loop
π Starting 080_open_ai_agents_sdk_human_in_the_loop agent...
β 080_open_ai_agents_sdk_human_in_the_loop agent started (PID: 92647, logs: /tmp/agentex-080_open_ai_agents_sdk_human_in_the_loop.log)
β³ Waiting for 080_open_ai_agents_sdk_human_in_the_loop agent to be ready...
β 080_open_ai_agents_sdk_human_in_the_loop agent is ready
π§ͺ Running tests for 080_open_ai_agents_sdk_human_in_the_loop...
========================================================== test session starts ==========================================================
platform darwin -- Python 3.13.5, pytest-8.4.2, pluggy-1.6.0 -- /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials/10_async/10_temporal/080_open_ai_agents_sdk_human_in_the_loop/.venv/bin/python
cachedir: .pytest_cache
rootdir: /Users/daniel.miller/codebases/scale-agentex-python/examples/tutorials
configfile: pytest.ini
plugins: asyncio-1.2.0, anyio-4.11.0, ddtrace-3.18.0
asyncio: mode=Mode.STRICT, debug=False, asyncio_default_fixture_loop_scope=None, asyncio_default_test_loop_scope=function
collected 2 items
tests/test_agent.py::TestNonStreamingEvents::test_send_event_and_poll_with_human_approval [DEBUG 080 POLL] Polling for initial task creation message...
[DEBUG 080 POLL] Initial message: Hello! I've received your task. Normally you can do some state initialization here, or just pass and
[DEBUG 080 POLL] Sending message: 'Please confirm my order'
[DEBUG 080 POLL] Waiting for child workflow to spawn...
[DEBUG 080 POLL] Received message - Type: text, Author: agent, Status: None
[DEBUG 080 POLL] Agent text update - Status: None, Length: 375
[DEBUG 080 POLL] Received message - Type: text, Author: user, Status: None
[DEBUG 080 POLL] Received message - Type: text, Author: agent, Status: DONE
[DEBUG 080 POLL] Agent text update - Status: DONE, Length: 0
[DEBUG 080 POLL] Received message - Type: tool_request, Author: agent, Status: DONE
[DEBUG 080 POLL] β Saw tool_request - agent is calling wait_for_confirmation tool
[DEBUG 080 POLL] π Child workflow should be spawned - will signal it to approve
[DEBUG 080 POLL] Sending approval signal to child workflow...
[DEBUG 080 POLL] β Approval signal sent successfully!
[DEBUG 080 POLL] Received message - Type: tool_response, Author: agent, Status: DONE
[DEBUG 080 POLL] β Saw tool_response - child workflow completed after approval
[DEBUG 080 POLL] Received message - Type: text, Author: agent, Status: DONE
[DEBUG 080 POLL] Agent text update - Status: DONE, Length: 74
[DEBUG 080 POLL] β Streaming complete!
[DEBUG 080 POLL] β Human-in-the-loop workflow completed successfully!
PASSED
tests/test_agent.py::TestStreamingEvents::test_send_event_and_stream PASSED
=========================================================== 2 passed in 7.41s ===========================================================
β Tests passed for 080_open_ai_agents_sdk_human_in_the_loop
β PASSED: 10_async/10_temporal/080_open_ai_agents_sdk_human_in_the_loop
π Stopping 080_open_ai_agents_sdk_human_in_the_loop agent...
Stopping 080_open_ai_agents_sdk_human_in_the_loop agent (PID: 92647)
β 080_open_ai_agents_sdk_human_in_the_loop agent stopped
Logs available at: /tmp/agentex-080_open_ai_agents_sdk_human_in_the_loop.log
================================================================================
Test Summary
Total: 6
Passed: 6
Failed: 0
π All tests passed!
(base) daniel.miller@SCMC4KVFJ06LL tutorials %