fix(approval): log empty gateway queue entries for diagnostics
This commit is contained in:
1 parent
5abe6e9128
commit
2db3e046d8
2 files changed
+4
No files matched your search
@@ -11234,6 +11234,8 @@ def _handle_approval_pending(handler, parsed):
|
||||
if raw:
|
||||
p = raw
|
||||
total = len(gw_queue)
|
||||
else:
|
||||
logger.warning("Gateway queue entry for %s has no .data attribute", sid)
|
||||
if p:
|
||||
return j(handler, {"pending": dict(p), "pending_count": total})
|
||||
return j(handler, {"pending": None, "pending_count": 0})
|
||||
|
||||
@@ -5938,6 +5938,8 @@ def _run_agent_streaming(
|
||||
raw = getattr(gw_queue[0], 'data', None) or {}
|
||||
if raw:
|
||||
p = dict(raw)
|
||||
else:
|
||||
logger.warning("Gateway queue entry for %s has no .data attribute", session_id)
|
||||
if p:
|
||||
put('approval', p)
|
||||
except ImportError:
|
||||
|
||||
Reference in new issue
Block a user