zhaoqingang
2025-03-06 e26a7859a8900b152e10961d91fa6ad19a8deb9c
app/service/v2/app_driver/chat_agent.py
@@ -9,6 +9,7 @@
    async def chat_completions(self, url, data, headers):
        complete_response = ""
        # print(data)
        async for line in self.http_stream(url, data, headers):
            # logger.error(line)
            if line.startswith("data:"):
@@ -46,6 +47,21 @@
            "files": files
        }
    @staticmethod
    async def complex_request_data(query: str, conversation_id: str, user: str, files: list=None, inputs: dict=None) -> dict:
        if not files:
            files = []
        if not inputs:
            inputs = {}
        return {
            "inputs": inputs,
            "query": query,
            "response_mode": "streaming",
            "conversation_id": conversation_id,
            "user": user,
            "files": files
        }
if __name__ == "__main__":
    async def aa():