chore(wren-ai-service): sql 2 answer streaming

[cyyeh]

SQL Answers Router

This router handles endpoints related to initiating SQL answer operations and retrieving their results.

Endpoints:

1. POST /sql-answers

   • Initiates an SQL answer operation
   • Request body: SqlAnswerRequest
     {
     "query": "user's question",
     "sql": "SELECT * FROM table_name WHERE condition", # Actual SQL statement
     "thread_id": "unique-thread-id", # Optional thread identifier for tracking
     "user_id": "user-id" # Optional user identifier for tracking
     }
   • Response: SqlAnswerResponse
     {
     "query_id": "unique-uuid" # Unique identifier for the initiated SQL operation
     }

2. GET /sql-answers/{query_id}/result

   • Retrieves the status and result of a SQL answer operation
   • Path parameter: query_id (str)
   • Response: SqlAnswerResultResponse
     {
     "query_id": "unique-uuid", # Unique identifier of the SQL answer operation
     "status": "preprocessing" | "succeeded" | "failed",
     "num_rows_used_in_llm": int | None,
     "error": { # Present only if status is "failed"
     "code": "OTHERS",
     "message": "Error description"
     }
     }

3. GET /sql-answers/{query_id}/streaming-result

   • Retrieves the streaming result of a SQL answer.
   • Path Parameter:
     • query_id: The unique identifier of the query.
   • Response:
     • Streaming response with the SQL answer.

Note: The actual SQL processing is performed in the background using FastAPI's BackgroundTasks.

[paopa]

overall LGTM. thanks for the hard work. a few comments leave.

[paopa]

LGTM