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

sub-job

MNEye · Load-Visit-Transform-Tables-Flow

Loads transform tables for Visits

called by Daily-Processing-Visits

sub-job MNEye/Load-Visit-Transform-Tables-Flow · db MNEye_ProdMirror · updated 2026-02-01

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 · MNEye
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 VisitDeltasqlload_visit_transform_tables_flow__load_visitdelta.sql
    ✨ Identifies appointments and insurance records requiring updates by comparing source timestamps against existing transformed visit data.
    writes VisitDelta · reads SourceAppointmentSourcePatientInsuranceTransformVisitVisitDelta
    ↳ feeds from Merge TransformVisit
  2. ▶Load-SourceAppointmentChain-Flowsub-job · 1↗
    1. Load SourceAppointmentChainsqlload_sourceappointmentchain_flow__load_sourceappointmentchain.sql
      ✨ Builds a chain of rescheduled appointments to identify the most recent record for each original appointment number.
      writes SourceAppointmentChain · reads SourceAppointmentVisitDelta
  3. Merge TransformVisitMergeSql
    writes TransformVisit · reads SourceAppointmentSourceAppointmentChainVisitDelta
    ↳ feeds from Load VisitDelta
    merge data source type=ThisDatabasetable name=TransformVisitmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  4. Load TransformVisitInsurancesqlload_visit_transform_tables_flow__load_transformvisitinsurance.sqldisabled
    ✨ Loads insurance coverage details for visits, determining coordination of benefits and mapping source payers to standardized insurance categories.
    writes TransformVisitInsurance · reads InsuranceMapSourcePatientSourcePatientInsuranceTransformPatientTransformVisitVisitDelta
  5. Merge TransformVisitInsuranceMergeSql
    writes TransformVisitInsurance · reads SourcePatientSourcePatientInsuranceTransformVisitVisitDelta
    ↳ feeds from Load VisitDelta, Merge TransformVisit
    merge data source type=ThisDatabasetable name=TransformVisitInsurancemerge mode=InsertUpdateHardDeletebulk copy timeout seconds=300bulk copy use table lock