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

sub-job

OrthoAlliance · Flow-34792-Transform

HL7 Transformation Layer

called by Flow-34792-Processing

sub-job OrthoAlliance/Flow-34792-Transform · db OrthoAlliance_ProdMirror · updated 2026-06-02

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

9 tasks · OrthoAlliance
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. TruncateOrthosVisitDeltasqlflow_34792_transform__truncateorthosvisitdelta.sql
    ✨ Clears the visit delta table to prepare for a fresh set of changed records in the current pipeline run.
    writes VisitDelta
  2. ImportHL7ADTCombinedsqlflow_34792_transform__importhl7adtcombined.sql
    ✨ Consolidates patient demographics and insurance details from HL7 messages into a unified table for further data transformation.
    writes ImportHL7ADTCombined
  3. TransformPatientsqlflow_34792_transform__transformpatient.sql
    ✨ Updates or inserts patient demographic records into the transformed patient table using the most recent HL7 message data.
    writes TransformPatient · reads HL7ArchiveHL7DeltaHL7VisitImportHL7ADTCombined
    ↳ feeds from ImportHL7ADTCombined
  4. ImportTransformPatientInsurancesqlflow_34792_transform__importtransformpatientinsurance.sql
    ✨ Loads patient insurance coverage details into a staging table, mapping source insurance identifiers to standardized insurance records.
    writes ImportTransformPatientInsurance · reads ImportHL7ADTCombinedInsuranceMap
    ↳ feeds from ImportHL7ADTCombined
  5. TransformPatientInsurance+VisitDeltasqlflow_34792_transform__transformpatientinsurance_visitdelta.sql
    ✨ Synchronizes patient insurance records and flags upcoming visits for reprocessing when insurance information changes.
    writes TransformPatientInsuranceVisitDelta · reads InsuranceChangesTransformVisitimporttransformpatientinsurance
    ↳ feeds from ImportTransformPatientInsurance, MergeTransformVisit+VisitDelta
  6. ImportTransformVisitsqlflow_34792_transform__importtransformvisit.sql
    ✨ Extracts and stages appointment data from HL7 messages, resolving provider identifiers and facility locations for visit transformation.
    writes ImportTransformVisit · reads HL7DeltaHL7VisitSourceProvider_34792
  7. MergeTransformVisit+VisitDeltasqlflow_34792_transform__mergetransformvisit_visitdelta.sql
    ✨ Updates the transformed visit table with staged appointment data and records new or modified visits in the delta tracking table.
    writes TransformVisitVisitDelta · reads ImportTransformVisitVisitDelta
    ↳ feeds from ImportTransformVisit, TransformPatientInsurance+VisitDelta, TruncateOrthosVisitDelta
  8. ImportTransformVisitInsurancesqlflow_34792_transform__importtransformvisitinsurance.sql
    ✨ Stages insurance information for specific visits by linking patient insurance records to visits flagged for update or creation.
    writes ImportTransformVisitInsurance · reads TransformPatientInsuranceTransformVisitVisitDelta
    ↳ feeds from MergeTransformVisit+VisitDelta, TransformPatientInsurance+VisitDelta, TruncateOrthosVisitDelta
  9. MergeTransformVisitInsurancesqlflow_34792_transform__mergetransformvisitinsurance.sql
    ✨ Refreshes the visit insurance table by replacing existing records with updated insurance details from the staging table.
    writes TransformVisitInsurance · reads ImportTransformVisitInsurance
    ↳ feeds from ImportTransformVisitInsurance