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

sub-job

RIA · Flow-HL7-Transform-Nightly

HL7 Transformation Layer

called by Flow-HL7-Processing-AutoSendLettersForFutureVisits

sub-job RIA/Flow-HL7-Transform-Nightly · 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-Nightly

4 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. TruncateVisitDelta and OrderSourceIDDeltasqlflow_hl7_transform_nightly__truncatevisitdelta_and_ordersourceiddelta.sql
    ✨ Clears the temporary tracking tables to prepare the pipeline for a fresh processing cycle.
    writes OrderSourceIDDeltaVisitDelta
  2. Recalculate Changed Bundlessqlflow_hl7_transform_nightly__recalculate_changed_bundles.sql
    ✨ Identifies and recalculates expected charges from service bundles for future visits to ensure accurate cost estimates.
    writes OrderSourceIDDeltaVisitDelta · reads BundleChargeTypeHL7OrderImportTransformVisitChargeTransformInsuranceMapServiceTypeTransformOrderSourceIDMapTransformVisitTransformVisitInsurance
    ↳ feeds from ImportTransformVisitCharge, TruncateVisitDelta and OrderSourceIDDelta
  3. ImportTransformVisitChargesqlflow_hl7_transform_nightly__importtransformvisitcharge.sql
    ✨ Builds a staging table of visit charges by extracting and formatting procedure codes and units from HL7 order bundles.
    writes ImportTransformVisitCharge · reads BundleChargeTypeHL7OrderImportTransformVisitChargeOrderSourceIDDeltaTransformInsuranceMapServiceTypeTransformOrderSourceIDMapTransformVisitInsurance
    ↳ feeds from Recalculate Changed Bundles, TruncateVisitDelta and OrderSourceIDDelta
  4. MergeTransformVisitChargesqlflow_hl7_transform_nightly__mergetransformvisitcharge.sql
    ✨ Synchronizes the visit charge transformation table by inserting, updating, or deleting records based on the latest imported charge data.
    writes TransformVisitCharge · reads ImportTransformVisitCharge
    ↳ feeds from ImportTransformVisitCharge