From 89d0819189b7f353756f2828f1601d2e7655e72a Mon Sep 17 00:00:00 2001 From: daniel Date: Thu, 7 May 2026 18:12:31 -0500 Subject: [PATCH] Add logging to streaming path in agent-runner --- src/lambdas/agent-runner/handler.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/lambdas/agent-runner/handler.py b/src/lambdas/agent-runner/handler.py index 5773a7f..cd35982 100644 --- a/src/lambdas/agent-runner/handler.py +++ b/src/lambdas/agent-runner/handler.py @@ -228,6 +228,8 @@ def handler(event, context): continue # Extract text delta from contentBlockDelta delta = event.get('event', {}).get('contentBlockDelta', {}).get('delta', {}) + if not isinstance(delta, dict): + continue token = delta.get('text', '') or event.get('data', '') if token: text_buffer += token @@ -236,11 +238,14 @@ def handler(event, context): or len(text_buffer) > 800 ) if flush and text_buffer.strip(): + print(f'[agent-runner] send chunk {len(text_buffer)}c to {chat_id}') send_telegram_direct(str(chat_id), bot_token, text_buffer.strip()) text_buffer = '' # Flush any remaining text + print(f'[agent-runner] stream done buffer={len(text_buffer)} bot_token_set={bool(bot_token)}') if text_buffer.strip() and bot_token: + print(f'[agent-runner] flushing {len(text_buffer)}c to {chat_id}') send_telegram_direct(str(chat_id), bot_token, text_buffer.strip()) print(f"[agent-runner] Completed session={session_id} actor={actor_id}")