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

sub-job

MNEye · Load-Source-Tables

called by Daily-Processing-Source-Data

sub-job MNEye/Load-Source-Tables · db MNEye_ProdMirror · updated 2025-12-08

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-Source-Tables

13 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. Merge SourceAppointmentMergeSql
    writes SourceAppointment · reads ImportAppointments
    merge data source type=ThisDatabasetable name=SourceAppointmentmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  2. Load SourcePatientInsurancesqlload_source_tables__load_sourcepatientinsurance.sql
    ✨ Loads patient insurance data while identifying inactive policies and calculating the coordination of benefits order for each coverage record.
    writes SourcePatientInsurance · reads ImportPatientInsurance
  3. Merge SourcePatientMergeSql
    writes SourcePatient · reads ImportPatient
    merge data source type=ThisDatabasetable name=SourcePatientmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  4. Load PatientsLoadPatients
    Upsert patient records into the patient dimension.
    · reads PatientSourcePatient
    ↳ feeds from Merge SourcePatient
    custom patient query
  5. Load SourceEncounterssqlload_source_tables__load_sourceencounters.sql
    ✨ Loads encounter records by transforming imported clinical and financial data into a standardized format for tracking patient visits and balances.
    writes SourceEncounters · reads ImportEncounters
  6. Load SourceEncounterInsurancesqlload_source_tables__load_sourceencounterinsurance.sql
    ✨ Loads and refreshes encounter-level insurance coverage details, including payer information and policy dates, into the source storage table.
    writes SourceEncounterInsurance · reads ImportEncounterInsurance
  7. Load SourceChargessqlload_source_tables__load_sourcecharges.sql
    ✨ Updates source charge records with procedure codes, financial balances, and rendering provider information for specific patient encounters.
    writes SourceCharges · reads ImportCharges
  8. Load SourceAdjustmentssqlload_source_tables__load_sourceadjustments.sql
    ✨ Loads financial adjustment data, including adjudication dates and reason codes, to track modifications made to patient account balances.
    writes SourceAdjustments · reads ImportAdjustments
  9. Load SourceTransactionDetailsqlload_source_tables__load_sourcetransactiondetail.sql
    ✨ Populates detailed transaction history, including allowed amounts and payments, while ensuring data integrity by removing duplicate or outdated records.
    writes SourceTransactionDetail · reads ImportTransactionDetail
  10. Merge SourceLocationsMergeSql
    writes SourceLocations · reads FacilityImportLocations
    merge data source type=ThisDatabasetable name=SourceLocationsmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  11. Load Provider (moved to Load-Entities)sqlload_source_tables__load_provider_moved_to_load_entities.sqldisabled
    ✨ Synchronizes provider information, such as NPI and taxonomy codes, by merging new and updated records from multiple source systems.
  12. Load SourcePayersqlload_source_tables__load_sourcepayer.sql
    ✨ Refreshes the master list of insurance payers by importing the latest payer identification and contact data into the source table.
    writes SourcePayer · reads ImportPayerSourcePayer
  13. Merge SourcechargemasterMergeSql
    writes SourceChargeMaster · reads ImportChargeMaster
    merge data source type=ThisDatabasetable name=SourceChargeMastermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock