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

sub-job

SWOrofacial · Flow-HL7-Transform

HL7 Transformation Layer

called by Flow-HL7-Processing

sub-job SWOrofacial/Flow-HL7-Transform · db SWOrofacial_ProdMirror · updated 2026-03-31

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-HL7-Transform

9 tasks · SWOrofacial
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_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_hl7_transform__importhl7adtcombined.sql
    ✨ Builds a combined view of patient demographics and insurance by merging the latest visit and patient records from HL7 messages.
    writes ImportHL7ADTCombined · reads HL7DeltaHL7PatientHL7Visit
  3. Merge TransformPatientMergeSql
    writes TransformPatient · reads ImportHL7ADTCombined
    ↳ feeds from ImportHL7ADTCombined
    merge data source type=ThisDatabasetable name=TransformPatientmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  4. ImportTransformPatientInsurancesqlflow_hl7_transform__importtransformpatientinsurance.sql
    ✨ Loads patient insurance details by unpivoting multiple coverage layers from combined HL7 data and mapping them to standardized insurance entities.
    writes ImportTransformPatientInsurance · reads ImportHL7ADTCombinedInsuranceMap
    ↳ feeds from ImportHL7ADTCombined
  5. TransformPatientInsurance+VisitDeltasqlflow_hl7_transform__transformpatientinsurance_visitdelta.sql
    ✨ Updates patient insurance records and flags future visits in the delta table when insurance changes are detected.
    writes TransformPatientInsuranceVisitDelta · reads InsuranceChangesTransformVisitimporttransformpatientinsurance
    ↳ feeds from ImportTransformPatientInsurance, MergeTransformVisit+VisitDelta
  6. ImportTransformVisitsqlflow_hl7_transform__importtransformvisit.sql
    ✨ Loads visit and appointment data from HL7 messages, determining the current status based on message type and schedule date.
    writes ImportTransformVisit · reads FacilityHL7ArchiveHL7DeltaHL7Visit
  7. MergeTransformVisit+VisitDeltasqlflow_hl7_transform__mergetransformvisit_visitdelta.sql
    ✨ Updates the main visit transformation table and flags new or modified visits in the delta table for downstream processing.
    writes TransformVisitVisitDelta · reads ImportTransformVisitVisitDelta
    ↳ feeds from ImportTransformVisit, TransformPatientInsurance+VisitDelta, TruncateVisitDelta
  8. ImportTransformVisitInsurancesqlflow_hl7_transform__importtransformvisitinsurance.sql
    ✨ Loads visit-specific insurance records by joining the latest patient insurance data with visits identified in the delta table.
    writes ImportTransformVisitInsurance · reads TransformPatientInsuranceTransformVisitVisitDelta
    ↳ feeds from MergeTransformVisit+VisitDelta, TransformPatientInsurance+VisitDelta, TruncateVisitDelta
  9. MergeTransformVisitInsurancesqlflow_hl7_transform__mergetransformvisitinsurance.sql
    ✨ Updates the visit insurance transformation table by replacing existing records with the latest imported insurance data for each visit.
    writes TransformVisitInsurance · reads ImportTransformVisitInsurance
    ↳ feeds from ImportTransformVisitInsurance