From c1cbb8ccdddae6c91e0a926bcccd2c503aa1de64 Mon Sep 17 00:00:00 2001 From: "Edgar R. M" Date: Wed, 9 Aug 2023 07:12:14 -0600 Subject: [PATCH] fix: Work around unsupported `json_serializer` and `json_deserializer` (#32) --- tap_snowflake/client.py | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/tap_snowflake/client.py b/tap_snowflake/client.py index 0e4c375..977c8d6 100644 --- a/tap_snowflake/client.py +++ b/tap_snowflake/client.py @@ -68,17 +68,16 @@ def get_sqlalchemy_url(cls, config: dict) -> str: return URL(**params) - def create_sqlalchemy_engine(self) -> sqlalchemy.engine.Engine: - """Return a new SQLAlchemy engine using the provided config. - - Developers can generally override just one of the following: - `sqlalchemy_engine`, sqlalchemy_url`. + def create_engine(self) -> sqlalchemy.engine.Engine: + """Create SQLAlchemy engine instance. Returns: - A newly created SQLAlchemy engine object. + A SQLAlchemy engine. """ return sqlalchemy.create_engine( - self.sqlalchemy_url, echo=False, pool_timeout=10 + self.sqlalchemy_url, + echo=False, + pool_timeout=10, ) # overridden to filter out the information_schema from catalog discovery