Skip to content

Commit 67f446e

Browse files
committed
fix: improve sqlalchemy session in threads
1 parent 885086e commit 67f446e

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

backend/apps/chat/task/llm.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -565,15 +565,15 @@ def generate_sql(self, _session: Session):
565565
self.record = save_sql_answer(session=_session, record_id=self.record.id,
566566
answer=orjson.dumps({'content': full_sql_text}).decode())
567567

568-
def generate_with_sub_sql(self, _session: Session, sql, sub_mappings: list):
568+
def generate_with_sub_sql(self, session: Session, sql, sub_mappings: list):
569569
sub_query = json.dumps(sub_mappings, ensure_ascii=False)
570570
self.chat_question.sql = sql
571571
self.chat_question.sub_query = sub_query
572572
dynamic_sql_msg: List[Union[BaseMessage, dict[str, Any]]] = []
573573
dynamic_sql_msg.append(SystemMessage(content=self.chat_question.dynamic_sys_question()))
574574
dynamic_sql_msg.append(HumanMessage(content=self.chat_question.dynamic_user_question()))
575575

576-
self.current_logs[OperationEnum.GENERATE_DYNAMIC_SQL] = start_log(session=_session,
576+
self.current_logs[OperationEnum.GENERATE_DYNAMIC_SQL] = start_log(session=session,
577577
ai_modal_id=self.chat_question.ai_modal_id,
578578
ai_modal_name=self.chat_question.ai_modal_name,
579579
operate=OperationEnum.GENERATE_DYNAMIC_SQL,
@@ -595,7 +595,7 @@ def generate_with_sub_sql(self, _session: Session, sql, sub_mappings: list):
595595

596596
dynamic_sql_msg.append(AIMessage(full_dynamic_text))
597597

598-
self.current_logs[OperationEnum.GENERATE_DYNAMIC_SQL] = end_log(session=_session,
598+
self.current_logs[OperationEnum.GENERATE_DYNAMIC_SQL] = end_log(session=session,
599599
log=self.current_logs[
600600
OperationEnum.GENERATE_DYNAMIC_SQL],
601601
full_message=[

0 commit comments

Comments
 (0)