import os
import snowflake.connector


credentials = snowflake.connector.connect(
user = os.environ['SNOWFLAKE_USER'],
password = os.environ['SNOWFLAKE_PASSWORD'],
role = os.environ['SNOWFLAKE_ROLE'],
account = 'orchard')


fd = open('Conflict_KPI_query.sql','r')
sqlFile = fd.read()
fd.close()


cur = credentials.cursor()
try:
    cur.execute(sqlFile)
finally:
    cur.close()