Skip to content

Commit a21045a

Browse files
author
kabulov kozim
committed
review fix 1, remove has_directories
1 parent b1f0d0e commit a21045a

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

ydb_sqlalchemy/sqlalchemy/__init__.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -589,7 +589,6 @@ def __init__(
589589
json_serializer=None,
590590
json_deserializer=None,
591591
_add_declare_for_yql_stmt_vars=False,
592-
has_directories=False,
593592
**kwargs,
594593
):
595594
super().__init__(**kwargs)
@@ -599,7 +598,6 @@ def __init__(
599598
# NOTE: _add_declare_for_yql_stmt_vars is temporary and is soon to be removed.
600599
# no need in declare in yql statement here since ydb 24-1
601600
self._add_declare_for_yql_stmt_vars = _add_declare_for_yql_stmt_vars
602-
self._has_directories = has_directories
603601

604602
def _describe_table(self, connection, table_name, schema=None):
605603
if schema is not None:
@@ -682,9 +680,7 @@ def do_commit(self, dbapi_connection: dbapi.Connection) -> None:
682680
dbapi_connection.commit()
683681

684682
def _fix_variable_name(self, variable):
685-
if self._has_directories:
686-
return variable.replace("/", "_")
687-
return variable
683+
return variable.replace("/", "__")
688684

689685
def _format_variables(
690686
self,

0 commit comments

Comments
 (0)