### snowflake cursor doesn't support string sseparation, thus this var is adjusted sf_system_history_1 = """ """ sf_event_generation_check_2 = """select count(*) "count" \ from "APP_ENABLEMENT"."APP_NOTIFICATION"."FACT_MILESTONE_NOTIFICATION_EXPORT" \ where CREATED_AT > dateadd(d, -8, current_date ());""" sf_data_input_check_3 = """select count(*) "count" \ from "APP_ENABLEMENT"."APP_NOTIFICATION"."DIM_STARRED_ISRC" \ where CREATED_AT > dateadd(d, -8, current_date ());""" sf_data_input_check_4 = """select count(*) "count" \ from "APP_ENABLEMENT"."RAW"."FACT_ARTIST_FOLLOWERS" \ where CREATED_AT > dateadd(d, -1, current_date ());""" sf_mapping_check_5 = """select GRAS_ARTIST_ID \ from "APP_ENABLEMENT"."APP_NOTIFICATION"."DIM_ARTIST" \ group by GRAS_ARTIST_ID \ having count(*) >1;""" sf_mapping_insertion_check_7 = """select * \ from APP_ENABLEMENT.APP_NOTIFICATION.DIM_STARRED_ISRC \ where GRAS_ARTIST_ID not in ( \ select GRAS_ARTIST_ID from APP_ENABLEMENT.APP_NOTIFICATION.DIM_ARTIST);""" sf_events_export_check_8 = """select distinct CREATED_AT \ from "APP_ENABLEMENT"."APP_NOTIFICATION"."FACT_MILESTONE_NOTIFICATION_EXPORT" \ where CREATED_AT > dateadd(d, -8, current_date ()); """ failure_count_increase_daily = """UPDATE failed_count SET failed_count = failed_count + 1, last = 'FAILED', last_updated = NOW() WHERE count_id = 'rtipnd';""" failure_count_to_zero_daily = """UPDATE failed_count SET failed_count = 0, last = 'OK', last_updated = NOW() WHERE count_id = 'rtipnd';""" failure_count_increase_weekly = """UPDATE failed_count SET failed_count = failed_count + 1, last = 'FAILED', last_updated = NOW() WHERE count_id = 'rtipnw';""" failure_count_to_zero_weekly = """UPDATE failed_count SET failed_count = 0, last = 'OK', last_updated = NOW() WHERE count_id = 'rtipnw';""" if __name__ == '__main__': pass