Legacy Pipeline Atlas worker-1snapshot 2026-07-15

sub-job

HeatonEye · Load-Visit-Transform-Tables-Flow

Loads transform tables for Visits

called by Daily-Visit-Processing-Flow

sub-job HeatonEye/Load-Visit-Transform-Tables-Flow · db HeatonEye_ProdMirror · updated 2026-04-30

task tree

What the sub-job runs

Tasks in order, each with what it does — typed stepsfrom the MDClarity task docs (click to open the reference), sub-jobsyou can expand inline (▶) to reveal their own tasks, and SQL steps summarized by Gemini (✨). Every step shows the tables it writes/reads and which earlier step it feeds from(sqlglot lineage).

sub-job

Load-Visit-Transform-Tables-Flow

5 tasks · HeatonEye
sub-job / Flow action SQL / native step▶ expand a sub-job inline · ↗ open it as its own page · a typed step opens its doc
  1. Load TempVisitDeltasqlload_visit_transform_tables_flow__load_tempvisitdelta.sql
    ✨ Identifies surgical visits and insurance updates that require processing by comparing recent source changes against previously transformed records.
  2. ▶Load-SourceAppointmentChain-Flowsub-job · 1↗
    1. Load SourceAppointmentChainsqlload_sourceappointmentchain_flow__load_sourceappointmentchain.sql
      ✨ Builds a history of rescheduled appointments to track the progression and relationship between original and updated visit records.
      writes SourceAppointmentChain · reads SourceAppointmentVisitDelta
  3. Load TransformVisitsqlload_visit_transform_tables_flow__load_transformvisit.sqldisabled
    ✨ Builds the transformed visit table by mapping appointment details, statuses, and service types from source data for processing.
    writes TransformVisit · reads FacilitySourceAppointmentSourceAppointmentChainSourceEventVisitDelta
  4. ExecuteMergeSqlExecuteMergeSql
    Synchronizes data from external sources into target tables by performing batched insert, update, and delete operations based on keys.
    writes TransformVisit · reads FacilitySourceAppointmentSourceAppointmentChainVisitDelta
    merge data source type=ThisDatabasetable name=TransformVisitmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  5. Load TransformVisitInsurancesqlload_visit_transform_tables_flow__load_transformvisitinsurance.sql
    ✨ Loads insurance coverage details for visits, determining coordination of benefits and mapping source payers to standardized insurance categories.
    writes TransformVisitInsurance · reads InsuranceMapSourcePatientSourcePatientInsuranceTransformPatientTransformVisitVisitDelta
    ↳ feeds from ExecuteMergeSql