streaming update:fix last event

ai-graphic · Apr 19, 2024 · 6771afe · 6771afe
1 parent c93fbb1
commit 6771afe
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/workflow.py b/src/workflow.py
@@ -65,6 +65,8 @@ async def stream_json_response_with_auth(api_url, api_key, msg_data, agent, thre
 
     # Print the complete message for the last event
     if prev_event is not None:
+        prev_data = prev_data.replace("````","`\n```")
+        prev_data = prev_data.replace("```", "\n```")
         print(f'Event: {prev_event}, Data: {prev_data}')
         await send_agent_message(agent[prev_event], thread_id, reply_id, prev_data, room_id)
     else: