diff --git a/textract-pipeline/src/lambda-layer/snowflake-connector/snowflake-lambda-layer.zip b/textract-pipeline/src/lambda-layer/snowflake-connector/sf-39-layer.zip similarity index 73% rename from textract-pipeline/src/lambda-layer/snowflake-connector/snowflake-lambda-layer.zip rename to textract-pipeline/src/lambda-layer/snowflake-connector/sf-39-layer.zip index 7266f63..d2b7dc4 100644 Binary files a/textract-pipeline/src/lambda-layer/snowflake-connector/snowflake-lambda-layer.zip and b/textract-pipeline/src/lambda-layer/snowflake-connector/sf-39-layer.zip differ diff --git a/textract-pipeline/src/lambda/database-interface/index.py b/textract-pipeline/src/lambda/database-interface/index.py index e840a62..30594cd 100644 --- a/textract-pipeline/src/lambda/database-interface/index.py +++ b/textract-pipeline/src/lambda/database-interface/index.py @@ -128,7 +128,7 @@ def get_snowflake_db_connection(secrets_name: str): logger.info(f'Using credentials: account={account}, user={user}, password=***, database={database}, ' f'warehouse={warehouse}') snowflake_connection = snowflake.connector.connect(account=account, user=user, password=password, database=database, - warehouse=warehouse, autocommit=True, schema='STG') + warehouse=warehouse,role=role, autocommit=True, schema='STG') logger.info(snowflake_connection) cursor = snowflake_connection.cursor() cursor.execute("SELECT * FROM STG.DIM_AUDIT LIMIT 10;")