Fix declare param_name cutting

ydb-platform · Nov 28, 2024 · 78714d5 · 78714d5
1 parent 6d6e304
commit 78714d5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ydb_sqlalchemy/sqlalchemy/__init__.py b/ydb_sqlalchemy/sqlalchemy/__init__.py
@@ -354,7 +354,7 @@ def _format_variables(
     def _add_declare_for_yql_stmt_vars_impl(self, statement, parameters_types):
         declarations = "\n".join(
             [
-                f"DECLARE $`{param_name[1:]}` as {str(param_type)};"
+                f"DECLARE $`{param_name[1:] if param_name.startswith('$') else param_name}` as {str(param_type)};"
                 for param_name, param_type in parameters_types.items()
             ]
         )