"""Query for creating the tracking table.""" CREATE_BULK_UPLOAD_TRACKING_TABLE = """ CREATE TABLE IF NOT EXISTS {snowflake_schema}.BULK_UPLOAD_TRACKING ( id INT AUTOINCREMENT, orchard_vendor_id INT, source_table VARCHAR(255), source_file_name VARCHAR(255), output_file_name VARCHAR(255), session_id VARCHAR(255), environment varchar(255), start_time TIMESTAMP_LTZ, end_time TIMESTAMP_LTZ, succeeded INT, failed INT, requeue_succeeded INT, requeue_failed INT, total_requests INT, assets_ingested INT, constraint BULK_UPLOAD_TRACKING_PK primary key (ID), constraint BULK_UPLOAD_TRACKING_UN unique ( ORCHARD_VENDOR_ID, SESSION_ID, START_TIME, ENVIRONMENT) ) """