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

sub-job

RIA · Flow-HL7-Transform-Concise

HL7 Transformation Layer - more efficient run for 1 minute interval

called by Flow-HL7-Processing

sub-job RIA/Flow-HL7-Transform-Concise · db RIA_ProdMirror · updated 2026-07-10

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-Concise

14 tasks · RIA
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_concise__truncatevisitdelta.sql
    ✨ Clears the visit delta table to prepare for a fresh set of changed records in the current pipeline run.
    writes VisitDelta
  2. TransformVisitIDMapsqlflow_hl7_transform_concise__transformvisitidmap.sql
    ✨ Builds unique source identifiers for new patient visits based on patient IDs and scheduled dates from incoming message data.
    writes TransformVisitIDMap · reads HL7DeltaTransformVisitIDMap
  3. OrderSourceIDDeltasqlflow_hl7_transform_concise__ordersourceiddelta.sql
    ✨ Updates order-level changes and identifies visits where all associated orders have been cancelled to refresh the visit status.
    writes OrderSourceIDDeltaTransformOrderSourceIDMap · reads HL7DeltaTransformOrderSourceIDMapTransformVisitIDMap
    ↳ feeds from TransformVisitIDMap
  4. ImportHL7ADTCombinedsqlflow_hl7_transform_concise__importhl7adtcombined.sql
    ✨ Builds a consolidated table of the most recent patient demographic and insurance information from admission, discharge, and transfer messages.
    writes ImportHL7ADTCombined · reads HL7DeltaHL7Patient
  5. TransformPatientsqlflow_hl7_transform_concise__transformpatient.sql
    ✨ Updates or inserts patient demographic records by merging the latest data from combined messages while ensuring only newer information is saved.
    writes TransformPatient · reads HL7DeltaHL7OrderImportHL7ADTCombinedPatientTransformPatient
    ↳ feeds from ImportHL7ADTCombined
  6. ImportTransformPatientInsurancesqlflow_hl7_transform_concise__importtransformpatientinsurance.sql
    ✨ Builds a staging table of patient insurance updates by deduplicating coverages and mapping source insurance identifiers to standard system values.
    writes ImportTransformPatientInsurance · reads ImportHL7ADTCombinedInsuranceMap
    ↳ feeds from ImportHL7ADTCombined
  7. Merge TransformPatientInsurance+VisitDeltasqlflow_hl7_transform_concise__merge_transformpatientinsurance_visitdelta.sql
    ✨ Updates patient insurance records and flags future visits for reprocessing when insurance details change.
    writes TransformPatientInsuranceVisitDelta · reads InsuranceChangesTransformVisitimporttransformpatientinsurance
    ↳ feeds from ImportTransformPatientInsurance, MergeTransformVisit+VisitDelta
  8. ImportTransformVisitsqlflow_hl7_transform_concise__importtransformvisit.sql
    ✨ Loads visit data from HL7 orders into a staging table while mapping clinical order statuses to standardized appointment statuses.
    writes ImportTransformVisit · reads HL7OrderOrderSourceIDDeltaTransformOrderSourceIDMap
    ↳ feeds from OrderSourceIDDelta
  9. MergeTransformVisit+VisitDeltasqlflow_hl7_transform_concise__mergetransformvisit_visitdelta.sql
    ✨ Synchronizes visit details with the main transform table and tracks modified future appointments for downstream updates.
    writes TransformVisitVisitDelta · reads ChangedVisitsVisitDelta
    ↳ feeds from Merge TransformPatientInsurance+VisitDelta, MergeTransformVisitCharge, TruncateVisitDelta
  10. ImportTransformVisitInsurancesqlflow_hl7_transform_concise__importtransformvisitinsurance.sql
    ✨ Stages the most recent insurance information for specific visits by linking patient insurance records to flagged visit changes.
    writes ImportTransformVisitInsurance · reads HL7OrderTransformOrderSourceIDMapTransformPatientInsuranceVisitDelta
    ↳ feeds from Merge TransformPatientInsurance+VisitDelta, MergeTransformVisit+VisitDelta, MergeTransformVisitCharge, OrderSourceIDDelta, TruncateVisitDelta
  11. MergeTransformVisitInsurancesqlflow_hl7_transform_concise__mergetransformvisitinsurance.sql
    ✨ Updates the main insurance transformation table by replacing existing records with newly imported and mapped insurance information.
    writes TransformVisitInsurance · reads ImportTransformVisitInsurance
    ↳ feeds from ImportTransformVisitInsurance
  12. Recalculate Changed Bundlessqlflow_hl7_transform_concise__recalculate_changed_bundles.sqldisabled
    ✨ Identifies and recalculates expected charges from service bundles for future visits to ensure accurate cost estimates.
    writes OrderSourceIDDeltaVisitDelta · reads BundleChargeTypeHL7OrderImportTransformVisitChargeTransformInsuranceMapServiceTypeTransformOrderSourceIDMapTransformVisitTransformVisitInsurance
  13. ImportTransformVisitChargesqlflow_hl7_transform_concise__importtransformvisitcharge.sql
    ✨ Loads visit charges into a staging table by matching scheduled services against insurance-specific or default billing bundles.
    writes ImportTransformVisitCharge · reads ChargeTypeHL7OrderImportTransformVisitChargeOrderSourceIDDeltaTransformBundleMapTransformInsuranceMapServiceTypeTransformOrderSourceIDMapTransformVisitInsurance
    ↳ feeds from MergeTransformVisitInsurance, OrderSourceIDDelta
  14. MergeTransformVisitChargesqlflow_hl7_transform_concise__mergetransformvisitcharge.sql
    ✨ Updates the master visit charge table and flags visits for recalculation when their associated billing codes or units change.
    writes TransformVisitChargeVisitDelta · reads ChangedChargesImportTransformVisitChargeVisitDelta
    ↳ feeds from ImportTransformVisitCharge, Merge TransformPatientInsurance+VisitDelta, MergeTransformVisit+VisitDelta, TruncateVisitDelta