Skip to content

Added 'asynio.run()' alternative to using await to run conversations. #29

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
IAmNo1Special wants to merge 2 commits into from
Closed

Added 'asynio.run()' alternative to using await to run conversations. #29

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
81311ed
Update tutorial.md
IAmNo1Special Apr 10, 2025
b746c8d
Merge branch 'google:main' into IAmNo1Special-patch-1
IAmNo1Special Apr 10, 2025
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
18 changes: 18 additions & 0 deletions docs/get-started/tutorial.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -252,6 +252,9 @@ async def run_conversation():

# Execute the conversation using await in an async context (like Colab/Jupyter)
await run_conversation()

# Alternatively, execute the conversation using asyncio
#asyncio.run(run_conversation())
```

**Expected Output:**
Expand Down Expand Up @@ -464,6 +467,9 @@ Now, execute the conversation. Ensure your API keys are correctly set in Step 0\
# Note: Requires API keys for Gemini, GPT, and Claude to be set correctly!
await run_multi_model_conversation()

# Alternatively, execute the conversation using asyncio
#asyncio.run(run__multi_model_conversation())

```

**Expected Output:**
Expand Down Expand Up @@ -714,6 +720,9 @@ if runner_root:
# Execute the conversation
# Note: This may require API keys for the models used by root and sub-agents!
await run_team_conversation()

# Alternatively, execute the conversation using asyncio
#asyncio.run(run_team_conversation())
else:
print("\n⚠️ Skipping agent team conversation as the root agent runner ('runner_root') is not available.")

Expand Down Expand Up @@ -1017,6 +1026,9 @@ if runner_root_stateful:
# Execute the conversation
await run_stateful_conversation()

# Alternatively, execute the conversation using asyncio
#asyncio.run(run_stateful_conversation())

# Inspect final session state after the conversation
final_session = session_service_stateful.get_session(APP_NAME, USER_ID_STATEFUL, SESSION_ID_STATEFUL)
if final_session:
Expand Down Expand Up @@ -1275,6 +1287,9 @@ if runner_root_model_guardrail:
# Execute the conversation
await run_guardrail_test_conversation()

# Alternatively, execute the conversation using asyncio
#asyncio.run(run_guardrail_conversation())

# Optional: Check state for the trigger flag set by the callback
final_session = session_service_stateful.get_session(APP_NAME, USER_ID_STATEFUL, SESSION_ID_STATEFUL)
if final_session:
Expand Down Expand Up @@ -1501,6 +1516,9 @@ if runner_root_tool_guardrail:
# Execute the conversation
await run_tool_guardrail_test()

# Alternatively, execute the conversation using asyncio
#asyncio.run(run_guardrail_test())

# Optional: Check state for the tool block trigger flag
final_session = session_service_stateful.get_session(APP_NAME, USER_ID_STATEFUL, SESSION_ID_STATEFUL)
if final_session:
Expand Down