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

sub-job

EugeneGI · Flow-MM-HL7-Transform

HL7 Transformation Layer

called by Flow-MM-HL7-Processing

sub-job EugeneGI/Flow-MM-HL7-Transform · db EugeneGI_ProdMirror · updated 2026-06-03

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

Flow-MM-HL7-Transform

9 tasks · EugeneGI
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. TruncateVisitDeltasqlflow_mm_hl7_transform__truncatevisitdelta.sql
    ✨ Clears the visit delta table to prepare for a fresh set of changed records in the current pipeline run.
    writes VisitDelta
  2. ImportHL7ADTCombinedsqlflow_mm_hl7_transform__importhl7adtcombined.sql
    ✨ Consolidates patient and visit information from various HL7 message types into a unified staging table for further transformation.
    writes ImportHL7ADTCombined
  3. TransformPatientsqlflow_mm_hl7_transform__transformpatient.sql
    ✨ Synchronizes patient demographic information by updating existing records or inserting new ones based on the latest HL7 data.
    writes TransformPatient · reads ImportHL7ADTCombined
    ↳ feeds from ImportHL7ADTCombined
  4. ImportTransformPatientInsurancesqlflow_mm_hl7_transform__importtransformpatientinsurance.sql
    ✨ Extracts and stages the most recent insurance details for patients from combined HL7 message data.
    writes ImportTransformPatientInsurance · reads ImportHL7ADTCombinedInsuranceMap
    ↳ feeds from ImportHL7ADTCombined
  5. TransformPatientInsurance+VisitDeltasqlflow_mm_hl7_transform__transformpatientinsurance_visitdelta.sql
    ✨ Updates patient insurance records and flags associated future visits in the delta table for reprocessing.
    writes TransformPatientInsuranceVisitDelta · reads InsuranceChangesTransformVisitimporttransformpatientinsurance
    ↳ feeds from ImportTransformPatientInsurance, MergeTransformVisit+VisitDelta
  6. ImportTransformVisitsqlflow_mm_hl7_transform__importtransformvisit.sql
    ✨ Builds the visit import table by extracting the latest appointment data from HL7 messages while mapping facilities and providers.
    writes ImportTransformVisit · reads FacilityHL7DeltaHL7VisitMMFacilityMapMMProviderMap
  7. MergeTransformVisit+VisitDeltasqlflow_mm_hl7_transform__mergetransformvisit_visitdelta.sql
    ✨ Updates the main visit transformation table with imported data and flags new visits in the delta tracking table.
    writes TransformVisitVisitDelta · reads ImportTransformVisitVisitDelta
    ↳ feeds from ImportTransformVisit, TransformPatientInsurance+VisitDelta, TruncateVisitDelta
  8. ImportTransformVisitInsurancesqlflow_mm_hl7_transform__importtransformvisitinsurance.sql
    ✨ Builds the insurance import table by linking the latest patient insurance details to visits identified in the delta tracking table.
    writes ImportTransformVisitInsurance · reads HL7DeltaTransformPatientInsuranceVisitDelta
    ↳ feeds from MergeTransformVisit+VisitDelta, TransformPatientInsurance+VisitDelta, TruncateVisitDelta
  9. MergeTransformVisitInsurancesqlflow_mm_hl7_transform__mergetransformvisitinsurance.sql
    ✨ Updates the visit insurance transformation table by merging the latest imported insurance records for each visit.
    writes TransformVisitInsurance · reads ImportTransformVisitInsurance
    ↳ feeds from ImportTransformVisitInsurance