(query_text, rag_instance, query_param)
| 17 | |
| 18 | |
| 19 | async def process_query(query_text, rag_instance, query_param): |
| 20 | try: |
| 21 | result = await rag_instance.aquery(query_text, param=query_param) |
| 22 | return {"query": query_text, "result": result}, None |
| 23 | except Exception as e: |
| 24 | return None, {"query": query_text, "error": str(e)} |
| 25 | |
| 26 | |
| 27 | def always_get_an_event_loop() -> asyncio.AbstractEventLoop: |
no test coverage detected