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

sub-job

OneGI · Flow-MM-Transform

HL7 Transformation Layer

called by Flow-MM-Processing

sub-job OneGI/Flow-MM-Transform · db OneGI_ProdMirror · updated 2026-06-11

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

8 tasks · OneGI
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_mm_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. TransformPatientTransformPatient
    writes TransformPatient · reads SourceOrganizationMMSourcePatientMM
    merge data source type=ThisDatabasetable name=TransformPatientmerge mode=InsertUpdateSoftDeletebulk copy timeout seconds=300bulk copy use table lock
  3. TransformPatientInsurance PatientDeltasqlflow_mm_transform__transformpatientinsurance_patientdelta.sql
    ✨ Identifies new or updated patient insurance records and configuration changes to flag patients requiring data transformation and reprocessing.
    writes FlowPatientDelta · reads FlowLogLastProcessingTimeFlowPatientDeltaInsuranceMapSourceOrganizationMMSourcePatientInsuranceMMSourcePatientMMTransformPatientInsurance
    ↳ feeds from Merge TransformPatientInsurance
  4. Merge TransformPatientInsuranceMergeSql
    writes TransformPatientInsurance · reads FlowPatientDeltaInsuranceMapSourcePatientInsuranceMM
    ↳ feeds from TransformPatientInsurance PatientDelta
    merge data source type=ThisDatabasetable name=TransformPatientInsurancemerge mode=InsertUpdateHardDeletebulk copy timeout seconds=300bulk copy use table lock
  5. TransformPatientInsurance VisitDeltasqlflow_mm_transform__transformpatientinsurance_visitdelta.sql
    ✨ Flags future appointments for reprocessing when associated patient insurance information has been updated or modified in the system.
    writes VisitDelta · reads FlowPatientDeltaTransformVisit
    ↳ feeds from MergeTransformVisit, TransformPatientInsurance PatientDelta
  6. VisitDeltasqlflow_mm_transform__visitdelta.sql
    ✨ Identifies new or updated colonoscopy appointments from source data to queue them for transformation and processing in the pipeline.
  7. MergeTransformVisitsqlflow_mm_transform__mergetransformvisit.sql
    ✨ Updates transformed visit records with current appointment, provider, and diagnosis details for visits flagged for reprocessing.
    writes TransformVisit · reads FacilitySourceAppointmentChainMMSourceColonoscopyTypePerAppointmentMMVisitDelta
    ↳ feeds from TransformPatientInsurance VisitDelta, TruncateVisitDelta
  8. MergeTransformVisitInsurancesqlflow_mm_transform__mergetransformvisitinsurance.sql
    ✨ Maps and loads patient insurance information into the transformed visit insurance table for visits identified in the delta set.
    writes TransformVisitInsurance · reads TransformPatientInsuranceTransformVisitVisitDelta
    ↳ feeds from Merge TransformPatientInsurance, MergeTransformVisit, TransformPatientInsurance VisitDelta, TruncateVisitDelta