Skip to content

Commit e0db3e7

Browse files
committed
Restore transaction flag check
1 parent 82f2da2 commit e0db3e7

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

datajoint/connection.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -124,6 +124,7 @@ def __init__(self, host, user, password, port=None, init_fun=None, use_tls=None)
124124
self.connection_id = self.query('SELECT connection_id()').fetchone()[0]
125125
else:
126126
raise errors.ConnectionError('Connection failed.')
127+
self._in_transaction = False
127128
self.schemas = dict()
128129
self.dependencies = Dependencies(self)
129130

@@ -159,8 +160,6 @@ def connect(self):
159160
if not(k == 'ssl_input' or
160161
k == 'ssl' and self.conn_info['ssl_input'] is None)})
161162
self._conn.autocommit(True)
162-
self._in_transaction = False
163-
164163

165164
def close(self):
166165
self._conn.close()

0 commit comments

Comments
 (0)