chore: change SqlExecutor node name to SQLExecutor

dynamiq/nodes/tools/__init__.py

@@ -7,6 +7,6 @@
 from .python import Python
 from .retriever import RetrievalTool
 from .scale_serp import ScaleSerpTool
-from .sql_executor import SqlExecutor
+from .sql_executor import SQLExecutor
 from .tavily import TavilyTool
 from .zenrows import ZenRowsTool

dynamiq/nodes/tools/sql_executor.py

@@ -14,7 +14,7 @@ class SQLInputSchema(BaseModel):
     query: str = Field(..., description="Parameter to provide a query that needs to be executed.")
 
 
-class SqlExecutor(ConnectionNode):
+class SQLExecutor(ConnectionNode):
     """
     A tool for SQL query execution.
 

examples/tools/use_sql.py

@@ -1,11 +1,11 @@
 from dynamiq.connections import connections
-from dynamiq.nodes.tools import SqlExecutor
+from dynamiq.nodes.tools import SQLExecutor
 
 
 def basic_requests_snowflake_example():
     snowflake_connection = connections.Snowflake()
 
-    snowflake_executor = SqlExecutor(connection=snowflake_connection)
+    snowflake_executor = SQLExecutor(connection=snowflake_connection)
     snowflake_insert = {
         "query": """INSERT INTO test1 (Name, Description)
         VALUES ('Name1', 'Description1'), ('Name2', 'Description2');"""
@@ -22,7 +22,7 @@ def basic_requests_snowflake_example():
 def basic_requests_mysql_example():
     mysql_connection = connections.MySQL()
 
-    mysql_executor = SqlExecutor(connection=mysql_connection)
+    mysql_executor = SQLExecutor(connection=mysql_connection)
     mysql_insert = {
         "query": """
     INSERT INTO test1 (`Name`, `Description`)

tests/integration/nodes/tools/test_sql_executor.py

@@ -1,7 +1,7 @@
 import pytest
 
 from dynamiq.connections import connections
-from dynamiq.nodes.tools.sql_executor import SqlExecutor
+from dynamiq.nodes.tools.sql_executor import SQLExecutor
 from dynamiq.runnables import RunnableResult, RunnableStatus
 
 
@@ -42,7 +42,7 @@ def mock_cursor_with_select(mocker, mock_fetchall_sql_response):
     ],
 )
 def test_mysql_postgres_select_execute(mock_fetchall_sql_response, connection, mock_cursor_with_select):
-    sql_tool = SqlExecutor(connection=connection)
+    sql_tool = SQLExecutor(connection=connection)
     output = mock_fetchall_sql_response
     input_data = {"query": """select * from test1"""}
 
@@ -86,7 +86,7 @@ def mock_cursor_with_none_description(mocker):
     ],
 )
 def test_non_select_queries_execution(mock_fetchall_sql_response, connection, mock_cursor_with_none_description):
-    sql_tool = SqlExecutor(connection=connection)
+    sql_tool = SQLExecutor(connection=connection)
     output = []
     input_data = {"query": """select * from test1"""}