iQor Snowflake Repository

Data

SQL source control for the Snowflake analytics and reporting platform that deploys production procedures, tasks, views, functions, and table DDL across recruiting, workforce management, payroll, client reporting, and infrastructure monitoring.

Overview

Centralized Snowflake SQL repository that governs production data pipelines, modeled assets, and reporting-ready objects across multiple business domains.

Business Purpose

Provide a controlled and auditable deployment backbone so analytics and reporting teams can deliver consistent, trusted outputs at scale.

Technology Stack

SnowflakeSQLTasksStored ProceduresViewsUDFs

Business Impact

Failures or drift in this repository can interrupt enterprise reporting pipelines, reduce metric trust, and delay operational decision-making.

As of 2026-08-19: 385 production SQL objects, 20 domain folders, 19 active domains and 1 legacy domain (CXONE).

Scale

385 production SQL objects in source control.

Coverage

20 domains with SQL assets (19 active, CXONE legacy).

Execution Model

53 active Snowflake tasks orchestrate repeatable pipelines.

Modeling Layer

83 modeled/reporting tables and 69 views for BI and operations.

Core Compute

161 procedures for ingestion, transformation, SCD maintenance, and metric population.

Shared Backbone

DATASTORE is the cross-domain foundation with 105 objects.

Task Ownership (Active Snowflake Tasks)

This repository currently runs 53 active Snowflake tasks. The portfolio is dominated by procedure-runner automation with scheduled root tasks and AFTER-chained dependencies that control downstream execution order for reporting and model refreshes.

Runtime Profile

53 Active Tasks

Current production automation is built around active tasks that drive daily/hourly pipelines across ingestion, transformation, dimensional maintenance, and reporting outputs.

Trigger Model

34 Scheduled Roots | 19 AFTER-Chained

The orchestration pattern uses cron-scheduled root tasks to start pipelines, then chained tasks to guarantee deterministic dependency sequencing.

Criticality

High-importance tasks dominate

Most active tasks are tagged High because they load production facts, dimensions, and reporting outputs across payroll, HR, contact center, and recruiting domains.

Domain Footprint

11 task-owning domain groups

Largest concentration is in DATASTORE and TALKPUSH, with substantial coverage in CXONE variants, PAYROLLDB, and METRO.

Domain Group	Task Count
DATASTORE (CEO, MART, MODELED)	19
TALKPUSH.MODELED	10
CXONEDEDICATED (MODELED + TPM)	6
PAYROLLDB.MODELED	7
METRO.MODELED	5
CXONE (MODELED + TPM)	1
IQORSURVEY_FF.MODELED	1
CXONERETAIL.MODELED	1
CLIENTMETRICS.FLOWERS1800	1
RESOURCEMONITORING.ZABBIX	1
SQANNEXGEN.MODELED	1

CEO backfill chain: DATASTORE.CEO.TASK_RUN_CEO schedules the root run, then TASK_RUN_NOTIFICATIONS and TASK_RUN_PAST_CEO_1 through TASK_RUN_PAST_CEO_4 cascade with AFTER dependencies for controlled historical reprocessing.
Retention pipeline: DATASTORE.MART.TASK_UPDATERETENTION_V2 triggers TASK_UPDATERETENTION_V2_PART2, then TASK_UPDATERETENTION_V2_PART3 to progress from base retention metrics into attrition holding and final summary outputs.
Talkpush fan-out: TASK_PROCESSDATA_V3 and TASK_BUILD_TALKPUSHFOLDERLOGS_SCD act as roots for downstream TASK_REFRESH_LIST_MASTER_* maintenance, rollups, and queue processing.
Metro timeline sequencing: TASK_REFRESH_CLEAN_TIMELINE feeds TASK_REFRESH_CORRECTED_TIMELINE and TASK_UPDATEAGENTSTATUSHISTORY_CLEAN_TIMELINE using AFTER chains to enforce timeline correction order.
Payroll staggered schedule: country-specific TASK_UPDATEPAYROLLDATA_* jobs run in a staggered cron window (US/Eastern 04:25-04:50) plus aggregate refresh to reduce contention.

Task Name	Schedule / Trigger	Runtime State	Importance
CLIENTMETRICS.FLOWERS1800.TASK_UPDATEAGENTSTATSTABLE	USING CRON 0 7 * * * US/Eastern	Active	High
CXONE.TPM.TASK_UPDATEAGENTSTATISTICS	USING CRON 25 7 * * * US/Eastern	Active	High
CXONEDEDICATED.MODELED.TASK_SPPOPULATEDIMAGENTSKILLTABLES	USING CRON 5,35 * * * * America/New_York	Active	High
CXONEDEDICATED.MODELED.TASK_SPPOPULATEFACTINTERVALTIME	USING CRON 25,55 * * * * America/New_York	Active	High
CXONEDEDICATED.MODELED.TASK_SPPOPULATEFACTSKILLCALLPROFILE	USING CRON 25,55 * * * * America/New_York	Active	High
CXONEDEDICATED.MODELED.TASK_SPPOPULATEFACTTAKEOVERS	USING CRON 25,55 * * * * America/New_York	Active	High
CXONEDEDICATED.MODELED.TASK_SP_POPULATE_CEH_SHORTABANDONS	USING CRON 15,45 * * * * America/New_York	Active	High
CXONEDEDICATED.TPM.TASK_UPDATEAGENTSTATISTICS	USING CRON 25 7 * * * US/Eastern	Active	High
CXONERETAIL.MODELED.TASK_SPPOPULATEDIMAGENTSKILLTABLES	USING CRON 5,35 * * * * America/New_York	Active	High
DATASTORE.CEO.TASK_RUN_CEO	USING CRON 30 7 * * * US/Eastern	Active	High
DATASTORE.CEO.TASK_RUN_NOTIFICATIONS	AFTER DATASTORE.CEO.TASK_RUN_CEO	Active	Medium
DATASTORE.CEO.TASK_RUN_PAST_CEO_1	AFTER DATASTORE.CEO.TASK_RUN_CEO	Active	Medium
DATASTORE.CEO.TASK_RUN_PAST_CEO_2	AFTER DATASTORE.CEO.TASK_RUN_PAST_CEO_1	Active	Medium
DATASTORE.CEO.TASK_RUN_PAST_CEO_3	AFTER DATASTORE.CEO.TASK_RUN_PAST_CEO_2	Active	Medium
DATASTORE.CEO.TASK_RUN_PAST_CEO_4	AFTER DATASTORE.CEO.TASK_RUN_PAST_CEO_3	Active	Medium
DATASTORE.MART.TASK_CHECK_EMPLOYEEDIMENSION	USING CRON 0 5 * * * US/Eastern	Active	High
DATASTORE.MART.TASK_GETEXITSURVEY	USING CRON 37 4 * * * US/Eastern	Active	High
DATASTORE.MART.TASK_UPDATEATTRITION	USING CRON 0 5 * * * US/Eastern	Active	High
DATASTORE.MART.TASK_UPDATERETENTION_V2	USING CRON 0 5 * * * US/Eastern	Active	High
DATASTORE.MART.TASK_UPDATERETENTION_V2_PART2	AFTER DATASTORE.MART.TASK_UPDATERETENTION_V2	Active	Medium
DATASTORE.MART.TASK_UPDATERETENTION_V2_PART3	AFTER DATASTORE.MART.TASK_UPDATERETENTION_V2_PART2	Active	Medium
DATASTORE.MART.TASK_UPDATE_EMPLOYEEDIMENSION	AFTER DATASTORE.MART.TASK_CHECK_EMPLOYEEDIMENSION	Active	Medium
DATASTORE.MODELED.TASK_ACD_FROM_CAPONE	USING CRON 0 6 * * * US/Eastern	Active	High
DATASTORE.MODELED.TASK_PRUNE_PROCEDURE_RUN_LOG	USING CRON 0 3 * * * US/Eastern	Active	High
DATASTORE.MODELED.TASK_UPDATE1800FLOWERCREDENTIALS	USING CRON 30 11 * * 2 US/Eastern	Active	High
DATASTORE.MODELED.TASK_UPDATECHEQINDATA	USING CRON 45 15 * * 1 US/Eastern	Active	High
DATASTORE.MODELED.TASK_UPDATEMODELEDTABLES	USING CRON 0 4 * * * US/Eastern	Active	High
DATASTORE.MODELED.TASK_UPDATEWAHAIOALERTS	USING CRON 30 4 * * * US/Eastern	Active	High
IQORSURVEY_FF.MODELED.TASK_UPDATEFLEXFORMANSWERS	USING CRON 5 * * * * US/Eastern	Active	High
METRO.MODELED.TASK_REFRESH_CLEAN_TIMELINE	USING CRON 10,40 * * * * UTC	Active	High
METRO.MODELED.TASK_REFRESH_CORRECTED_TIMELINE	AFTER METRO.MODELED.TASK_REFRESH_CLEAN_TIMELINE	Active	Medium
METRO.MODELED.TASK_UPDATEAGENTSTATHISTORY_CHILD1_AUXREPORT	AFTER METRO.MODELED.TASK_UPDATEAGENTSTATUSHISTORY	Active	Medium
METRO.MODELED.TASK_UPDATEAGENTSTATUSHISTORY	USING CRON 7,37 * * * * US/Eastern	Active	High
METRO.MODELED.TASK_UPDATEAGENTSTATUSHISTORY_CLEAN_TIMELINE	AFTER METRO.MODELED.TASK_REFRESH_CLEAN_TIMELINE	Active	Medium
PAYROLLDB.MODELED.TASK_UPDATEPAYROLLDATA_ALL	USING CRON 50 4 * * * US/Eastern	Active	High
PAYROLLDB.MODELED.TASK_UPDATEPAYROLLDATA_CA	USING CRON 35 4 * * * US/Eastern	Active	High
PAYROLLDB.MODELED.TASK_UPDATEPAYROLLDATA_IN	USING CRON 45 4 * * * US/Eastern	Active	High
PAYROLLDB.MODELED.TASK_UPDATEPAYROLLDATA_PH	USING CRON 25 4 * * * US/Eastern	Active	High
PAYROLLDB.MODELED.TASK_UPDATEPAYROLLDATA_TT	USING CRON 40 4 * * * US/Eastern	Active	High
PAYROLLDB.MODELED.TASK_UPDATEPAYROLLDATA_US	USING CRON 30 4 * * * US/Eastern	Active	High
PAYROLLDB.MODELED.TASK_UPDATE_TIMEQEY_AGGREGATE	USING CRON 30 4 * * * US/Eastern	Active	High
RESOURCEMONITORING.ZABBIX.TASK_UPDATE_TERMS	USING CRON 30 5 * * * US/Eastern	Active	High
SQANNEXGEN.MODELED.TASK_REFRESH_CREDITONE_EVALUATIONDETAILS	USING CRON 0 * * * * UTC	Active	High
TALKPUSH.MODELED.TASK_BUILD_TALKPUSHFOLDERLOGS_SCD	AFTER TALKPUSH.MODELED.TASK_PROCESSDATA_V3	Active	Medium
TALKPUSH.MODELED.TASK_PROCESSDATA_V3	USING CRON 15 14 * * * US/Eastern	Active	High
TALKPUSH.MODELED.TASK_PROCESSREQUISITIONDATA	USING CRON 5 5 * * * US/Eastern	Active	High
TALKPUSH.MODELED.TASK_PROCESS_TALKPUSH_ATTEMPT_CEFR_QUEUE	AFTER TALKPUSH.MODELED.TASK_REFRESH_LIST_MASTER_ROLLUP	Active	Medium
TALKPUSH.MODELED.TASK_REFRESH_CLIENT_PIPELINE	AFTER TALKPUSH.MODELED.TASK_PROCESSDATA_V3	Active	Medium
TALKPUSH.MODELED.TASK_REFRESH_LIST_MASTER_ENDORSED	AFTER TALKPUSH.MODELED.TASK_BUILD_TALKPUSHFOLDERLOGS_SCD	Active	Medium
TALKPUSH.MODELED.TASK_REFRESH_LIST_MASTER_LEADCHASERS	AFTER TALKPUSH.MODELED.TASK_BUILD_TALKPUSHFOLDERLOGS_SCD	Active	Medium
TALKPUSH.MODELED.TASK_REFRESH_LIST_MASTER_ROLLUP	AFTER TALKPUSH.MODELED.TASK_REFRESH_LIST_MASTER_ENDORSED	Active	Medium
TALKPUSH.MODELED.TASK_REFRESH_LIST_MASTER_SHORTLISTED	AFTER TALKPUSH.MODELED.TASK_BUILD_TALKPUSHFOLDERLOGS_SCD	Active	Medium
TALKPUSH.MODELED.TASK_REFRESH_LIST_MASTER_TALENTPOOL	AFTER TALKPUSH.MODELED.TASK_BUILD_TALKPUSHFOLDERLOGS_SCD	Active	Medium
CXONE.MODELED.TASK_SPINTERVALCONTACTSYNC	USING CRON 25,55 * * * * America/New_York	Suspended	Low
CXONE.MODELED.TASK_SPPOPULATEDIMAGENTSKILLTABLES	USING CRON 10 * * * * America/New_York	Suspended	Low
CXONE.MODELED.TASK_SPPOPULATEDIMAGENTSKILLTABLES_V2	USING CRON 10,40 * * * * America/New_York	Suspended	Low
CXONE.MODELED.TASK_SPPOPULATEFACTINTERVALTIME_TPM_V2	USING CRON 25,55 * * * * America/New_York	Suspended	Low
CXONE.MODELED.TASK_SPPOPULATEFACTINTERVALTIME_TPM_V3	USING CRON 25,55 * * * * America/New_York	Suspended	Low
CXONE.MODELED.TASK_SPPOPULATEFACTINTERVALTIME_V2	USING CRON 25,55 * * * * America/New_York	Suspended	Low
CXONE.MODELED.TASK_SPPOPULATEFACTINTERVALTIME_V3	USING CRON 25,55 * * * * America/New_York	Suspended	Low
CXONE.MODELED.TASK_SPPOPULATEFACTTAKEOVERS	USING CRON 25,55 * * * * America/New_York	Suspended	Low
CXONEDEDICATED.MODELED.TASK_SPINTERVALCONTACTSYNC	USING CRON 25,55 * * * * America/New_York	Suspended	Low
CXONERETAIL.MODELED.TASK_SPINTERVALCONTACTSYNC	USING CRON 25,55 * * * * America/New_York	Suspended	Low
DATASTORE.MART.TASK_CHECK_ENGAGE	USING CRON 30 3 * * * US/Eastern	Suspended	Low
DATASTORE.MART.TASK_CHECK_PROQOR	USING CRON 30 3 * * * US/Eastern	Suspended	Low
DATASTORE.MART.TASK_GETESAT	USING CRON 45 4 * * 0,1 US/Eastern	Suspended	Low
IQORSURVEY_FF.MODELED.TASK_PROCESS_FEMA	USING CRON 15/30 * * * * US/Eastern	Suspended	Low

What This Repository Does

Ingests and normalizes source data from platforms like Talkpush, CXOne, TimeQey, Freshservice, FlexForms, and HubSpot-related sources.
Builds modeled tables (facts, dimensions, domain marts) consumed by analytics and operations.
Maintains enterprise dimensions, including daily Type-2 SCD history for employee context.
Schedules repeatable pipelines through Snowflake tasks and procedure chains.
Publishes reporting-ready views and functions for BI and operational consumers.
Captures execution metadata for monitoring, troubleshooting, and execution-level auditability.

Folder Conventions

DOMAIN/
    MODELED/
        PROCEDURES/     -- Stored procedures (SP_*)
        TASKS/          -- Snowflake tasks (TASK_*)
        VIEWS/          -- Views (VW_*)
        FUNCTIONS/      -- UDFs (FN_*)
        TABLES/         -- Table DDL (CREATE TABLE IF NOT EXISTS)

CXONE domains may include TPM for agent statistics procedures and tasks.
Some domains use intermediate folders instead of MODELED (for example CLIENTMETRICS/FLOWERS1800, EIS/RECLEADS, RESOURCEMONITORING/ZABBIX).
WORKING is reserved for ad hoc validation SQL and is not a production deployment path.

Domain Snapshot

Domain	Objects	Status
DATASTORE	105	Active
TALKPUSH	59	Active
PAYROLLDB	38	Active
CXONEDEDICATED	42	Active
CXONERETAIL	40	Active
CXONE	20	Legacy
FRESHSERVICE	9	Active
IQORSURVEY_FF	12	Active
CLIENTMETRICS/FLOWERS1800	5	Active
CMS_REPORTING_R17/ROOT	2	Active
CREDITONE	1	Active
METRO	21	Active
JUMPCREW	18	Active
AMAZONCONNECT	2	Active
LIVEVOX	1	Active
CISCOBELL	1	Active
EIS/RECLEADS	1	Active
PROQOR	1	Active
SQANNEXGEN	1	Active
RESOURCEMONITORING/ZABBIX	6	Active
DOCUMENTATION	11	Reference
BOILERPLATE	5	Reference

Object Inventory

Object Type	Count
Stored Procedures	161
Tables	83
Tasks	64
Views	69
Functions	7
Sequences	1
Total SQL Objects	385

High-Value Assets

Employee master history: DIM_EMPLOYEETS plus update/check tasks drive cross-domain HR joins.
Procedure execution observability: centralized execution logging in DATASTORE.MODELED for diagnostics and auditability.
Recruiting and lead lifecycle: TALKPUSH is the largest domain and supports lead-stage and pipeline metrics.
CXONE performance pipelines: CXONEDEDICATED and CXONERETAIL power interval and contact-center reporting.
Payroll reporting layer: PAYROLLDB procedures and TimeQey integrations feed multi-country payroll analytics.
Resource monitoring automation: Zabbix tasks, procedures, tables, and views support termination and infrastructure audit controls.

Business outcomes: stronger production reliability through standardized SQL deployment patterns, faster incident triage via centralized execution logging, and higher enterprise trust in cross-domain reporting outputs.

Visual architecture map of the Snowflake SQL repository domains, object model, and deployment layout — Snowflake SQL repository overview map (updated 2026-08-19).

Shared Infrastructure

All production DML procedures log execution through DATASTORE.MODELED.SP_LOG_PROCEDURE_RUN into TBL_PROCEDURE_RUN_LOG.
DIM_EMPLOYEETS is the central Type-2 SCD employee dimension and a shared join target across major reporting domains.
Shared UDF backbone includes GET_TENURE, GET_VALUE, and FIND_POSITION in DATASTORE.MODELED, with TALKPUSH-specific helpers in TALKPUSH.MODELED.