Remove fallback adapter.send() — streaming consumer handles delivery

This commit is contained in:
daniel
2026-05-07 18:17:48 -05:00
parent 89d0819189
commit 83b937c20e

View File

@@ -297,19 +297,7 @@ async def main(payload: dict, context):
finally: finally:
_typing_active = False _typing_active = False
session_manager.close() session_manager.close()
# Delivery handled by agent-runner streaming consumer — no direct send here
# Deliver final response if agent didn't call send_message
if not messaging.was_sent() and final_message:
msg = final_message
if isinstance(msg, dict):
content = msg.get('content', {})
if isinstance(content, dict):
msg = content.get('text', str(content))
elif isinstance(content, list):
msg = ' '.join(c.get('text', '') for c in content if isinstance(c, dict))
else:
msg = str(content)
adapter.send(str(msg))
app.run() app.run()