"""Sync Transaction Types from Snowflake to S3.""" from pathlib import Path from snowflake_connector.etl_connector import SnowflakeSQLExecutor from abacus_etl_tools import config def main(): """Copy data from snowflake to s3.""" raw_sql = Path( 'abacus_etl_tools/queries/load_transaction_types_from_sf.sql' ).read_text() sql = raw_sql.format(**{ 'db': config.SNOWFLAKE.get('db'), 'schema': config.SNOWFLAKE.get('schema'), **config.TRANSACTION_TYPE_SYNC }) with SnowflakeSQLExecutor(config.SNOWFLAKE) as executor: executor.execute(sql)