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

sub-job

StrideCare · Flow-HL7-Transform

HL7 Transformation Layer

called by Flow-HL7-Processing

sub-job StrideCare/Flow-HL7-Transform · db StrideCare_ProdMirror · updated 2026-04-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-HL7-Transform

9 tasks · StrideCare
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
    ✨ Consolidates patient demographics and insurance information from HL7 ADT messages into a unified staging table for further processing.
    writes ImportHL7ADTCombined
  3. TransformPatientsqlflow_hl7_transform__transformpatient.sql
    ✨ Synchronizes the patient transformation table by merging the latest demographic updates from both ADT and visit-based HL7 messages.
    writes TransformPatient · reads HL7ArchiveHL7DeltaHL7VisitImportHL7ADTCombined
    ↳ feeds from ImportHL7ADTCombined
  4. ImportTransformPatientInsurancesqlflow_hl7_transform__importtransformpatientinsurance.sql
    ✨ Extracts and maps the most recent primary, secondary, and tertiary insurance details from consolidated HL7 messages for each patient.
    writes ImportTransformPatientInsurance · reads ImportHL7ADTCombinedInsuranceMap
    ↳ feeds from ImportHL7ADTCombined
  5. TransformPatientInsurance+VisitDeltasqlflow_hl7_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_hl7_transform__importtransformvisit.sql
    ✨ Builds the visit transformation table by mapping appointment details, facilities, and resolving provider identifiers from HL7 scheduling messages.
    writes ImportTransformVisit · reads HL7DeltaHL7VisitSourceProvider_33143
  7. MergeTransformVisit+VisitDeltasqlflow_hl7_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, TruncateVisitDelta
  8. ImportTransformVisitInsurancesqlflow_hl7_transform__importtransformvisitinsurance.sql
    ✨ Builds the visit insurance import table by mapping patient insurance records to specific visits based on coordination of benefits.
    writes ImportTransformVisitInsurance · reads TransformPatientInsuranceTransformVisitVisitDelta
    ↳ feeds from MergeTransformVisit+VisitDelta, TransformPatientInsurance+VisitDelta, TruncateVisitDelta
  9. MergeTransformVisitInsurancesqlflow_hl7_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