fix: correct method signature for _model_schema_to_text; update OpenAI model name and fix parameter naming in PydanticAgent; enhance SQL query verification with logging and error handling

src/services/_data_extractor.py

@@ -34,7 +34,7 @@ class DataExtractorService:
     async def __aexit__(self, exc_type, exc_value, traceback):
         pass
 
-    async def _model_schema_to_text(model_class) -> str:
+    async def _model_schema_to_text(self, model_class) -> str:
         """Convert SQLAlchemy model schema to LLM-friendly text."""
         mapper = inspect(model_class)
         table_name = model_class.__tablename__

src/utils/_pydantic_agent.py

@@ -18,15 +18,15 @@ class PydanticAgent:
         self
     ):
         self._system_prompt = SQL_QUERY_EXTRACTOR_PROMPT
-        self._openai_model_name = os.getenv("OPENAI_MODEL_NAME", "gpt-5.2")
+        self._openai_model_name = os.getenv("OPENAI_MODEL_NAME", "gpt-4.1-mini")
         self._openai_model = OpenAIResponsesModel(
-            model=self._openai_model_name,
+            model_name=self._openai_model_name,
         )
         self._agent = Agent(
             system_prompt=self._system_prompt,
             model=self._openai_model,
             output_type=SQLQueryExtractor,
-            responses_model_settings=OpenAIResponsesModelSettings(temperature=0.0),
+            model_settings=OpenAIResponsesModelSettings(temperature=0.0),
             tools=[self._verify_sql_query],
             retries=5,
         )
@@ -37,7 +37,8 @@ class PydanticAgent:
     async def __aexit__(self, exc_type, exc_value, traceback):
         pass
 
-    async def _verify_sql_query(self, sql_query):
+    async def _verify_sql_query(self, sql_query: str) -> bool|str:
+        logger.info(f"Verifying SQL query: {sql_query}")
         try:
             words_shoould_not_present_in_sql_query = [
                 "DELETE", 
@@ -58,7 +59,8 @@ class PydanticAgent:
             async with DatabaseConfig.async_session() as session:
                 await session.execute(text(sql_query))
         except Exception as e:
-            raise e
+            logger.error(e)
+            return str(e) + "\nPlease generate SQL Query again"
         return True
 
     async def _run_with_backoff(self, agent, *args, retries=5, **kwargs):