|
|
@@ -106,9 +106,7 @@ def _data_adjust(obj):
|
|
|
for key, value in data.items():
|
|
|
if isinstance(value, datetime):
|
|
|
data[key] = value.timestamp()
|
|
|
- #print(
|
|
|
- "--------------------------------====================================11221212212121212121"
|
|
|
- )
|
|
|
+ #print("--------------------------------====================================11221212212121212121")
|
|
|
#print(data)
|
|
|
# data["parallel_tool_calls"] = True
|
|
|
return data
|
|
|
@@ -152,9 +150,7 @@ def sub_stream(
|
|
|
#print(channel)
|
|
|
#print(x_index)
|
|
|
x_index, data = read_event(channel, x_index)
|
|
|
- #print(
|
|
|
- "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaassssssssssssssssssssssssssssssssssssss"
|
|
|
- )
|
|
|
+ #print("aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaassssssssssssssssssssssssssssssssssssss")
|
|
|
#print(data)
|
|
|
if not data:
|
|
|
break
|
|
|
@@ -289,9 +285,7 @@ class StreamEventHandler:
|
|
|
"thread_id": "",
|
|
|
"metadata": {"usage": chunk.usage.json()},
|
|
|
}
|
|
|
- #print(
|
|
|
- "pub_message_usagepub_message_usagepub_message_usagepub_message_usagepub_message_usagepub_message_usagepub_message_usagepub_message_usage==========================================================="
|
|
|
- )
|
|
|
+ #print("pub_message_usagepub_message_usagepub_message_usagepub_message_usagepub_message_usagepub_message_usagepub_message_usagepub_message_usage===========================================================")
|
|
|
#print(data)
|
|
|
self.pub_event(
|
|
|
events.ThreadMessageInProgress(
|
