Skip to content

Commit

Permalink
Fix cyclical references
Browse files Browse the repository at this point in the history
  • Loading branch information
kesmit13 committed Jul 31, 2024
1 parent ef380ba commit 0ed670c
Showing 1 changed file with 7 additions and 6 deletions.
13 changes: 7 additions & 6 deletions singlestoredb/mysql/connection.py
Original file line number Diff line number Diff line change
Expand Up @@ -716,6 +716,7 @@ def close(self):
Error : If the connection is already closed.
"""
self._result = None
if self.host == 'singlestore.com':
return
if self._closed:
Expand Down Expand Up @@ -1909,12 +1910,12 @@ def __init__(self, connection, unbuffered=False):
encoding_errors=connection.encoding_errors,
).items() if v is not UNSET
}
self._read_rowdata_packet = functools.partial(
_singlestoredb_accel.read_rowdata_packet, self, False,
)
self._read_rowdata_packet_unbuffered = functools.partial(
_singlestoredb_accel.read_rowdata_packet, self, True,
)

def _read_rowdata_packet(self, *args, **kwargs):
return _singlestoredb_accel.read_rowdata_packet(self, False, *args, **kwargs)

def _read_rowdata_packet_unbuffered(self, *args, **kwargs):
return _singlestoredb_accel.read_rowdata_packet(self, True, *args, **kwargs)


class LoadLocalFile:
Expand Down

0 comments on commit 0ed670c

Please sign in to comment.