apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-05-28 19:05:31 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Move tracing toggle and max child turns to .env file

Browse source
This commit is contained in:
akhisud3195 2025-05-06 22:47:35 +05:30
parent e59a8b75cf
commit 69316aee60
5 changed files with 29 additions and 32 deletions
Download patch file Download diff file Expand all files Collapse all files

4
apps/rowboat_agents/src/graph/core.py
View file

@ -192,9 +192,6 @@ async def run_turn_streamed(
async for event in stream_result.stream_events():
try:
print('-'*100)
print(f"Event: {event}")
print('-'*100)
# Handle web search events
if event.type == "raw_response_event":
web_search_messages = handle_web_search_event(event, current_agent)
@ -211,7 +208,6 @@ async def run_turn_streamed(
# Handle agent transfer
elif event.type == "agent_updated_stream_event":
# print(f"\nAgent transfer attempt: {current_agent.name} -> {event.new_agent.name}")
# Skip self-transfers
if current_agent.name == event.new_agent.name:

31
apps/rowboat_agents/src/graph/execute_turn.py
View file

@ -281,7 +281,7 @@ async def run_streamed(
messages,
external_tools=None,
tokens_used=None,
enable_tracing=False # Changed default to False
enable_tracing=False
):
"""
Wrapper function for initializing and running the Swarm client in streaming mode.
@ -319,25 +319,26 @@ async def run_streamed(
add_trace_processor(trace_processor)
trace_processor_added = True
# Create a trace context only if tracing is enabled
trace_ctx = None
if enable_tracing:
trace_ctx = trace(f"Agent turn: {agent.name}")
trace_ctx.__enter__()
# Get the stream result
# Get the stream result without trace context first
stream_result = Runner.run_streamed(agent, formatted_messages)
# Patch the stream_events method to ensure trace context is maintained if tracing is enabled
# If tracing is enabled, wrap the stream_events to handle tracing
if enable_tracing:
original_stream_events = stream_result.stream_events
async def wrapped_stream_events():
try:
async for event in original_stream_events():
yield event
finally:
if trace_ctx:
trace_ctx.__exit__(None, None, None)
# Create trace context inside the async function
with trace(f"Agent turn: {agent.name}") as trace_ctx:
try:
async for event in original_stream_events():
yield event
except GeneratorExit:
# Handle generator exit gracefully
raise
except Exception as e:
print(f"Error in stream events: {str(e)}")
raise
stream_result.stream_events = wrapped_stream_events
return stream_result