We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
FATAL: sorry, too many clients already
1 parent 2eede7e commit 5a70027Copy full SHA for 5a70027
target_postgres/connector.py
@@ -180,8 +180,10 @@ def copy_table_structure(
180
181
@contextmanager
182
def _connect(self) -> t.Iterator[sqlalchemy.engine.Connection]:
183
- with self._engine.connect().execution_options() as conn:
+ engine = self._engine
184
+ with engine.connect().execution_options() as conn:
185
yield conn
186
+ engine.dispose()
187
188
def drop_table(
189
self, table: sqlalchemy.Table, connection: sqlalchemy.engine.Connection
@@ -800,9 +802,7 @@ def column_exists( # type: ignore[override]
800
802
)
801
803
804
def __del__(self):
- """
- Dispose underlying SQLAlchemy engine object.
805
+ """Dispose underlying SQLAlchemy engine object."""
806
if self._cached_engine is not None:
807
self._cached_engine.dispose()
808
0 commit comments