added together ai agent

controller.py

@@ -620,18 +620,22 @@ async def csv_chart(request: dict, authorization: str = Header(None)):
         #      return {"orchestrator_response": jsonable_encoder(orchestrator_answer)}
         
         # Next, try the groq-based method
-        groq_result = await loop.run_in_executor(
-            process_executor, groq_chart, csv_url, query
-        )
-        logger.info(f"Groq chart result: {groq_result}")
-        if isinstance(groq_result, str) and groq_result != "Chart not generated":
-            unique_file_name =f'{str(uuid.uuid4())}.png'
-            logger.info("Uploading the chart to supabase...")
-            image_public_url = await upload_file_to_supabase(f"{groq_result}", unique_file_name, chat_id=chat_id)
-            logger.info("Image uploaded to Supabase and Image URL is... ", {image_public_url})
-            os.remove(groq_result)
-            return {"image_url": image_public_url}
+        # groq_result = await loop.run_in_executor(
+        #     process_executor, groq_chart, csv_url, query
+        # )
+        # logger.info(f"Groq chart result: {groq_result}")
+        # if isinstance(groq_result, str) and groq_result != "Chart not generated":
+        #     unique_file_name =f'{str(uuid.uuid4())}.png'
+        #     logger.info("Uploading the chart to supabase...")
+        #     image_public_url = await upload_file_to_supabase(f"{groq_result}", unique_file_name, chat_id=chat_id)
+        #     logger.info("Image uploaded to Supabase and Image URL is... ", {image_public_url})
+        #     os.remove(groq_result)
+        #     return {"image_url": image_public_url}
             # return FileResponse(groq_result, media_type="image/png")
+            
+        result = query_csv_agent(csv_url,query)
+        logger.info("together ai result ==>", result)
+        return {"orchestrator_response": jsonable_encoder(result)}
           
         # Fallback: try langchain-based again
         # logger.error("Groq chart generation failed, trying langchain....")
@@ -647,9 +651,9 @@ async def csv_chart(request: dict, authorization: str = Header(None)):
         #    os.remove(langchain_paths[0])
         #    return {"image_url": image_public_url}
            # return FileResponse(langchain_paths[0], media_type="image/png")
-        else:
-           logger.error("All chart generation methods failed")
-           return {"answer": "error"}
+        # else:
+        #    logger.error("All chart generation methods failed")
+        #    return {"answer": "error"}
 
     except Exception as e:
         logger.error(f"Critical chart error: {str(e)}")