Simrun Basuita
07/05/2023, 8:22 AMautocommit=False
argument to snowflake.connector.connect
(https://docs.snowflake.com/developer-guide/python-connector/python-connector-example#using-context-manager-to-connect-and-control-transactions).
How can I get a Snowflake connection with autocommit=False
from SnowflakeResource.get_connection()
?jamie
07/05/2023, 3:27 PMSnowflakeResource
accepts an autocommit
configuration that is forwarded to the snowflake connection https://docs.dagster.io/_apidocs/libraries/dagster-snowflake#dagster_snowflake.SnowflakeResourceSimrun Basuita
07/05/2023, 3:49 PMSimrun Basuita
07/05/2023, 3:50 PMSimrun Basuita
07/05/2023, 3:51 PMjamie
07/05/2023, 3:56 PMsnowflake.connector.Connection
object has an autocommit
method you could use
@asset
def my_asset(snowflake: SnowflakeResource):
with snowflake.get_connection() as conn:
conn.autocommit(False)
https://docs.snowflake.com/en/developer-guide/python-connector/python-connector-api#object-connectionSimrun Basuita
07/05/2023, 5:50 PMFĂ©lix Tremblay
09/28/2023, 11:50 AMSimrun Basuita
09/28/2023, 12:23 PM