gmakstutis/openrag
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Update chat_service.py

Browse source
This commit is contained in:
Edwin Jose 2025-09-10 12:41:04 -04:00
parent 67063441f5
commit fe88378d05
1 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/services/chat_service.py
View file

@ -391,7 +391,7 @@ class ChatService:
local_metadata[response_id] = conversation_metadata local_metadata[response_id] = conversation_metadata
# 2. Get actual conversations from Langflow database (source of truth for messages) # 2. Get actual conversations from Langflow database (source of truth for messages)
print(f"[DEBUG] Attempting to fetch Langflow history for user: {user_id}") logger.debug(f"Attempting to fetch Langflow history for user: {user_id}")
langflow_history = ( langflow_history = (
await langflow_history_service.get_user_conversation_history( await langflow_history_service.get_user_conversation_history(
user_id, flow_id=LANGFLOW_CHAT_FLOW_ID user_id, flow_id=LANGFLOW_CHAT_FLOW_ID
@ -462,24 +462,24 @@ class ChatService:
) )
if langflow_history.get("conversations"): if langflow_history.get("conversations"):
print( logger.debug(
f"[DEBUG] Added {len(langflow_history['conversations'])} historical conversations from Langflow" f"Added {len(langflow_history['conversations'])} historical conversations from Langflow"
) )
elif langflow_history.get("error"): elif langflow_history.get("error"):
print( logger.debug(
f"[DEBUG] Could not fetch Langflow history for user {user_id}: {langflow_history['error']}" f"Could not fetch Langflow history for user {user_id}: {langflow_history['error']}"
) )
else: else:
print(f"[DEBUG] No Langflow conversations found for user {user_id}") logger.debug(f"No Langflow conversations found for user {user_id}")
except Exception as e: except Exception as e:
print(f"[ERROR] Failed to fetch Langflow history: {e}") logger.error(f"Failed to fetch Langflow history: {e}")
# Continue with just in-memory conversations # Continue with just in-memory conversations
# Sort by last activity (most recent first) # Sort by last activity (most recent first)
all_conversations.sort(key=lambda c: c.get("last_activity", ""), reverse=True) all_conversations.sort(key=lambda c: c.get("last_activity", ""), reverse=True)
print( logger.debug(
f"[DEBUG] Returning {len(all_conversations)} conversations ({len(local_metadata)} from local metadata)" f"[DEBUG] Returning {len(all_conversations)} conversations ({len(local_metadata)} from local metadata)"
) )