All notable changes to this project will be documented in this file.
The format is based on Keep a Changelog, and this project adheres to Semantic Versioning.
- Ability to specify what kind of cursor is used in a query - #71
- User-provided connect kwargs have precedence over the default - [#97] (PrefectHQ#97)
- Type hints for **kwargs are now parsed correctly - [#98] (PrefectHQ#98)
Released on February 10th, 2022.
- Using
private_key_path
inSnowflakeCredentials
- #67
Released on January 9th, 2022.
- Improper validation of
private_key_path
andprivate_key_passphrase
fields toSnowflakeCredentials
- #59
Released on January 4th, 2022.
private_key_path
andprivate_key_passphrase
fields toSnowflakeCredentials
- #59
- Do not start connection upon instantiating
SnowflakeConnector
until its methods are called - #58
password
in favor ofprivate_key_passphrase
field inSnowflakeConnector
- #59
Released on December 30th, 2022.
fetch_size
andpoll_frequency_s
toSnowflakeConnector
fields - #53reset_cursors
,fetch_one
,fetch_many
,fetch_all
,execute
,execute_many
, andclose
methods toSnowflakeConnector
fields - #53
- Added
get_client
method toSnowflakeCredentials
to enable more customization of connection creation - #51
Released on December 21st, 2022.
- The
okta_endpoint
field inSnowflakeCredentials
; useendpoint
instead - #45.
- Fixed misleading validator message in
SnowflakeCredentials
whenauthenticator
isokta_endpoint
- #45.
Released on October 5th, 2022.
snowflake_query_sync
#34.
Released on August 22nd, 2022.
poll_frequency_seconds
tosnowflake_query
andsnowflake_multiquery
#29.
Released on August 15th, 2022.
Note, with this release, the database
, warehouse
and schema
fields from SnowflakeCredentials
have been migrated to SnowflakeConnector
:
from prefect_snowflake.credentials import SnowflakeCredentials
from prefect_snowflake.database import SnowflakeConnector
...
snowflake_credentials = SnowflakeCredentials(
account="account",
user="user",
password="password",
)
snowflake_connector = SnowflakeConnector(
database="database",
warehouse="warehouse",
schema="schema",
credentials=snowflake_credentials
)
Tasks now accept SnowflakeConnector
instead of SnowflakeCredentials
:
snowflake_query(..., snowflake_connector)
- Moved the keywords,
database
,warehouse
, andschema
fromcredentials.SnowflakeCredentials
intodatabase.SnowflakeConnector
- #24 - Moved the method
get_connection
fromcredentials.SnowflakeCredentials
intodatabase.SnowflakeConnector
- #24 authenticator
field inSnowflakeCredentials
toLiteral
type - #25
- Removed the keywords,
database
andwarehouse
, fromsnowflake_query
andsnowflake_multiquery
- #24
- Fixed revealing the input password nested under
connect_params
when loggingSnowflakeCredentials
- #24
Released on July 26th, 2022.
- Fixed credentials by calling
get_secret_value()
onSecretStr
keywords - #19
Released on July 22nd, 2022.
- Added setup.py entry point - #18
Released on July 19th, 2022.
- Support for running multiple queries in a one session and in a transaction - #9
- Converted
SnowflakeCredentials
into aBlock
- #13. - Updated tests to be compatible with core Prefect library (v2.0b9) and bumped required version - #14.
Released on May 13th, 2022.
snowflake_query
task - #5