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

sub-job

Wildflower · Flow-Transform-LoadTransformTables

called by Flow-Processing

sub-job Wildflower/Flow-Transform-LoadTransformTables · db Wildflower_ProdMirror · updated 2025-09-17

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

6 tasks · Wildflower
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. Truncate VisitDeltasqlflow_transform_loadtransformtables__truncate_visitdelta.sql
    Clears the visit delta table to prepare for a fresh set of changed records in the current pipeline run.
    writes VisitDelta
  2. VisitDelta + Logssqlflow_transform_loadtransformtables__visitdelta_logs.sql
    Identifies new or updated visit records and logs the batch process to track incremental data changes.
    writes BatchProcessLogVisitDelta · reads BatchProcessLogSourceVisitSourceVisitInsuranceVisitDelta
    ↳ feeds from Truncate VisitDelta
  3. Transform Patientsqlflow_transform_loadtransformtables__transform_patient.sql
    Updates patient demographic information and contact details while standardizing gender values for the transformation layer.
    writes TransformPatient · reads BatchProcessLogSourcePatient
    ↳ feeds from VisitDelta + Logs
  4. Transform Visitsqlflow_transform_loadtransformtables__transform_visit.sql
    Refreshes visit details like status, time, and provider for records identified as changed in the current batch.
    writes TransformVisit · reads SourceVisitVisitDelta
    ↳ feeds from Truncate VisitDelta, VisitDelta + Logs
  5. Transform VisitInsurancesqlflow_transform_loadtransformtables__transform_visitinsurance.sql
    Updates insurance coverage details for changed visits by mapping source insurance identifiers to standardized internal values.
    writes TransformVisitInsurance · reads InsuranceMapSourceVisitInsuranceVisitDelta
    ↳ feeds from Truncate VisitDelta, VisitDelta + Logs
  6. Transform VisitChargesqlflow_transform_loadtransformtables__transform_visitcharge.sql
    Calculates and updates visit charges by mapping CPT codes and modifiers to standardized service types and charge definitions.
    writes TransformVisitCharge · reads ChargeTypeSourceVisitVisitDelta
    ↳ feeds from Truncate VisitDelta, VisitDelta + Logs