Spaces:
Sleeping
Sleeping
BolyosCsaba commited on
Commit Β·
e30c300
1
Parent(s): 4d7b8a6
added klogs
Browse files- src/floor_manager.py +21 -2
src/floor_manager.py
CHANGED
|
@@ -169,7 +169,8 @@ class FloorManager:
|
|
| 169 |
continue
|
| 170 |
|
| 171 |
try:
|
| 172 |
-
logger.
|
|
|
|
| 173 |
|
| 174 |
response = requests.post(
|
| 175 |
agent_info.service_url,
|
|
@@ -183,7 +184,25 @@ class FloorManager:
|
|
| 183 |
|
| 184 |
response.raise_for_status()
|
| 185 |
results[speaker_uri] = True
|
| 186 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 187 |
|
| 188 |
except requests.exceptions.Timeout:
|
| 189 |
logger.error(f"β Timeout sending to {speaker_uri}")
|
|
|
|
| 169 |
continue
|
| 170 |
|
| 171 |
try:
|
| 172 |
+
logger.info(f"π€ Sending envelope to {speaker_uri} at {agent_info.service_url}")
|
| 173 |
+
logger.debug(f"π€ Envelope content: {envelope_dict}")
|
| 174 |
|
| 175 |
response = requests.post(
|
| 176 |
agent_info.service_url,
|
|
|
|
| 184 |
|
| 185 |
response.raise_for_status()
|
| 186 |
results[speaker_uri] = True
|
| 187 |
+
|
| 188 |
+
# Log the response from the agent
|
| 189 |
+
logger.info(f"β Envelope delivered to {speaker_uri} - Status: {response.status_code}")
|
| 190 |
+
|
| 191 |
+
# Try to parse and log agent's response
|
| 192 |
+
try:
|
| 193 |
+
response_data = response.json()
|
| 194 |
+
logger.info(f"π₯ Response from {speaker_uri}: {response_data}")
|
| 195 |
+
|
| 196 |
+
# Check if agent sent any events back
|
| 197 |
+
if "openFloor" in response_data:
|
| 198 |
+
events = response_data.get("openFloor", {}).get("events", [])
|
| 199 |
+
if events:
|
| 200 |
+
logger.info(f"π Agent {speaker_uri} sent {len(events)} event(s) in response")
|
| 201 |
+
for event in events:
|
| 202 |
+
event_type = event.get("eventType")
|
| 203 |
+
logger.info(f" - Event type: {event_type}")
|
| 204 |
+
except ValueError:
|
| 205 |
+
logger.debug(f"Response from {speaker_uri} is not JSON: {response.text[:200]}")
|
| 206 |
|
| 207 |
except requests.exceptions.Timeout:
|
| 208 |
logger.error(f"β Timeout sending to {speaker_uri}")
|