Update app/agents/crew_pipeline.py

app/agents/crew_pipeline.py

@@ -249,7 +249,7 @@ def run_pipeline(user_query: str, session_id: str = None):
     Each session_id keeps its own history.
     """
     if session_id is None:
-        session_id = str(uuid.uuid4())  # fallback unique session
+        session_id = str(uuid.uuid4())
 
     # Language detection
     lang_label, prob = detect_language(user_query, top_k=1)[0]
@@ -264,42 +264,45 @@ def run_pipeline(user_query: str, session_id: str = None):
 
     intent, extra = detect_intent(translated_query)
 
-    #  Load conversation history
+    # Load conversation history
     history = memory_store.get_history(session_id) or []
     if len(history) > MAX_HISTORY_MESSAGES:
         history = history[-MAX_HISTORY_MESSAGES:]
 
     
-    history.append({"role": "user", "content": translated_query})
-
-    
     system_prompt = (
         "You are FarmLingua, an AI assistant for Nigerian farmers. "
-        "Answer directly without repeating the question. "
-        "Use clear farmer-friendly English with emojis . "
-        "Avoid jargon and irrelevant details. "
+        "Answer questions directly and accurately with helpful farming advice. "
+        "Use clear, simple language with occasional emojis 🌾. "
+        "Be concise and focus on practical, actionable information. "
         "If asked who built you, say: 'KawaFarm LTD developed me to help farmers.'"
-      
     )
 
+
+    context_info = ""
     
     if intent == "weather" and extra:
         weather_text = get_weather(extra)
-        history.append({"role": "user", "content": f"Rewrite this weather update simply for farmers:\n{weather_text}"})
-        messages_for_qwen = build_messages_from_history(history, system_prompt)
-        english_answer = run_qwen(messages_for_qwen, max_new_tokens=256)
-    else:
-        if intent == "live_update":
-            context = retrieve_docs(translated_query, config.LIVE_VS_PATH)
-            if context:
-                history.append({"role": "user", "content": f"Latest agricultural updates:\n{context}"})
-        if intent == "low_confidence":
-            context = retrieve_docs(translated_query, config.STATIC_VS_PATH)
-            if context:
-                history.append({"role": "user", "content": f"Reference information:\n{context}"})
-
-        messages_for_qwen = build_messages_from_history(history, system_prompt)
-        english_answer = run_qwen(messages_for_qwen, max_new_tokens=700)
+        context_info = f"\n\nCurrent weather information:\n{weather_text}"
+    elif intent == "live_update":
+        rag_context = retrieve_docs(translated_query, config.LIVE_VS_PATH)
+        if rag_context:
+            context_info = f"\n\nLatest agricultural updates:\n{rag_context}"
+    elif intent == "low_confidence":
+        rag_context = retrieve_docs(translated_query, config.STATIC_VS_PATH)
+        if rag_context:
+            context_info = f"\n\nRelevant information:\n{rag_context}"
+
+    
+    user_message = translated_query + context_info
+    history.append({"role": "user", "content": user_message})
+
+
+    messages_for_qwen = build_messages_from_history(history, system_prompt)
+    
+   
+    max_tokens = 256 if intent == "weather" else 700
+    english_answer = run_qwen(messages_for_qwen, max_new_tokens=max_tokens)
 
     # Save assistant reply
     history.append({"role": "assistant", "content": english_answer})
@@ -307,15 +310,16 @@ def run_pipeline(user_query: str, session_id: str = None):
         history = history[-MAX_HISTORY_MESSAGES:]
     memory_store.save_history(session_id, history)
 
-    # Translate back if needed
+    
     final_answer = (
         translate_text(english_answer, src_lang="eng_Latn", tgt_lang=lang_label)
         if lang_label != "eng_Latn"
         else english_answer
     )
     final_answer = strip_markdown(final_answer)
+    
     return {
         "session_id": session_id,
         "detected_language": SUPPORTED_LANGS.get(lang_label, "Unknown"),
         "answer": final_answer
-    }
+    }