From ea7fec111e03f84efbba63266a1930fee07a51b0 Mon Sep 17 00:00:00 2001 From: Umang Mistry Date: Tue, 27 Feb 2024 15:52:01 -0600 Subject: [PATCH] Fixed typo in sp --- .../R__002_LOAD_TRAINING_RESULTS_SP.SQL | 12 ++++++------ .../R__003_LOAD_ATTEMPTS_SP.sql | 15 ++++++++------- 2 files changed, 14 insertions(+), 13 deletions(-) diff --git a/snowflake/scripts/training_interface/R__002_LOAD_TRAINING_RESULTS_SP.SQL b/snowflake/scripts/training_interface/R__002_LOAD_TRAINING_RESULTS_SP.SQL index fa21bc0..ea3b3cf 100644 --- a/snowflake/scripts/training_interface/R__002_LOAD_TRAINING_RESULTS_SP.SQL +++ b/snowflake/scripts/training_interface/R__002_LOAD_TRAINING_RESULTS_SP.SQL @@ -10,7 +10,7 @@ BEGIN procedure_name := 'LOAD_TRAINING_RESULTS'; - call stg.log_audit(procedure_name, 'Section 1', 99, 'START'); + call stg.log_audit(:procedure_name, 'Section 1', 99, 'START'); -- Create or replace stage with dynamic file name EXECUTE IMMEDIATE 'CREATE OR REPLACE STAGE STG.TRAINING_RESULTS_STAGE @@ -18,8 +18,8 @@ BEGIN URL = ''s3://doczy-dev-infra-raw-data-ingestion/training_interface/' || :file_name || ''' FILE_FORMAT = (FORMAT_NAME = ''STG.CSV_HEADER'');'; - call stg.log_audit(procedure_name, 'Section 1', 99, 'END'); - call stg.log_audit(procedure_name, 'Section 2', 99, 'START'); + call stg.log_audit(:procedure_name, 'Section 1', 99, 'END'); + call stg.log_audit(:procedure_name, 'Section 2', 99, 'START'); -- Copy command to load data COPY INTO STG.TRAINING_RESULTS FROM ( @@ -40,17 +40,17 @@ BEGIN FILE_FORMAT = (FORMAT_NAME = 'STG.CSV_HEADER') ON_ERROR = CONTINUE; - call stg.log_audit(procedure_name, 'Section 2', 99, 'END'); + call stg.log_audit(:procedure_name, 'Section 2', 99, 'END'); - call stg.log_audit(procedure_name, 'Section 3', 99, 'START'); + call stg.log_audit(:procedure_name, 'Section 3', 99, 'START'); INSERT INTO DOCZY_DEV.STG.DIM_AUDIT (AUDIT_SID, TABLE_NAME, SOURCE_FILE_NAME, LOAD_DATE, SOURCE_COUNT) SELECT STG.AUDIT_SID.NEXTVAL, 'STG.TRAINING_RESULTS',* FROM (SELECT DISTINCT METADATA$FILENAME, CURRENT_TIMESTAMP(), max(METADATA$FILE_ROW_NUMBER) from @DOCZY_DEV.STG.TRAINING_RESULTS_STAGE group by 1,2); - call stg.log_audit(procedure_name, 'Section 3', 99, 'END'); + call stg.log_audit(:procedure_name, 'Section 3', 99, 'END'); RETURN 'Setup, Load, and Audit Complete'; END; diff --git a/snowflake/scripts/training_interface/R__003_LOAD_ATTEMPTS_SP.sql b/snowflake/scripts/training_interface/R__003_LOAD_ATTEMPTS_SP.sql index 035dbd7..557cbc9 100644 --- a/snowflake/scripts/training_interface/R__003_LOAD_ATTEMPTS_SP.sql +++ b/snowflake/scripts/training_interface/R__003_LOAD_ATTEMPTS_SP.sql @@ -5,21 +5,21 @@ EXECUTE AS CALLER AS $$ DECLARE - prcedure_name varchar; + procedure_name varchar; BEGIN procedure_name := 'LOAD_ATTEMPT_LOGS'; - call stg.log_audit(procedure_name, 'Section 1', 99, 'START'); + call stg.log_audit(:procedure_name, 'Section 1', 99, 'START'); -- Create or replace stage with dynamic file name EXECUTE IMMEDIATE 'CREATE OR REPLACE STAGE STG.ATTEMPT_LOGS_STAGE STORAGE_INTEGRATION = dev_bucket_integration URL = ''s3://doczy-dev-infra-raw-data-ingestion/training_interface/' || :file_name || ''' FILE_FORMAT = (FORMAT_NAME = ''STG.CSV_HEADER'');'; - call stg.log_audit(procedure_name, 'Section 1', 99, 'END'); + call stg.log_audit(:procedure_name, 'Section 1', 99, 'END'); - call stg.log_audit(procedure_name, 'Section 2', 99, 'START'); + call stg.log_audit(:procedure_name, 'Section 2', 99, 'START'); -- Copy command to load data COPY INTO STG.TRAINING_ATTEMPT_LOGS FROM @@ -37,15 +37,16 @@ BEGIN FILE_FORMAT = (FORMAT_NAME = 'STG.CSV_HEADER') ON_ERROR = CONTINUE; - call stg.log_audit(procedure_name, 'Section 2', 99, 'END'); + call stg.log_audit(:procedure_name, 'Section 2', 99, 'END'); - call stg.log_audit(procedure_name, 'Section 3', 99, 'START'); + call stg.log_audit(:procedure_name, 'Section 3', 99, 'START'); + INSERT INTO DOCZY_DEV.STG.DIM_AUDIT (AUDIT_SID, TABLE_NAME, SOURCE_FILE_NAME, LOAD_DATE, SOURCE_COUNT) SELECT STG.AUDIT_SID.NEXTVAL, 'STG.TRAINING_ATTEMPT_LOGS',* FROM (SELECT DISTINCT METADATA$FILENAME, CURRENT_TIMESTAMP(), max(METADATA$FILE_ROW_NUMBER) from @DOCZY_DEV.STG.TRAINING_RESULTS_STAGE group by 1,2); - call stg.log_audit(procedure_name, 'Section 3', 99, 'END'); + call stg.log_audit(:procedure_name, 'Section 3', 99, 'END'); RETURN 'Setup, Load, and Audit Complete'; END;