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