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

sub-job

MannEye · Flow-Transform-Visits

FHIR Transformation Layer

called by Flow-FHIR-Processing

sub-job MannEye/Flow-Transform-Visits · db MannEye_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-Visits

5 tasks · MannEye
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. ImportTransformVisitsqlflow_transform_visits__importtransformvisit.sql
    ✨ Loads incoming appointment data from source FHIR records into a staging table for further processing and transformation.
    writes ImportTransformVisit · reads FHIRIncomingSourceAppointmentFHIRProcessBatch
  2. MergeTransformVisitsqlflow_transform_visits__mergetransformvisit.sql
    ✨ Merges staged appointment data into the main transformation table by replacing existing records with the most recent source information.
    writes TransformVisit · reads ImportTransformVisit
    ↳ feeds from ImportTransformVisit
  3. ImportTransformVisitInsurancesqlflow_transform_visits__importtransformvisitinsurance.sql
    ✨ Extracts and maps primary, secondary, and tertiary insurance details from incoming appointment records into a staging table.
    writes ImportTransformVisitInsurance · reads FHIRIncomingSourceAppointmentFHIRProcessBatchInsuranceMap
  4. MergeTransformVisitInsurancesqlflow_transform_visits__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
  5. AugmentTransformVisitsqlflow_transform_visits__augmenttransformvisit.sqldisabled
    ✨ Refines visit service types by mapping insurance-specific codes to standardized eligibility categories for more accurate coverage verification.
    writes TransformVisit · reads EligibilityMapping2024ImportTransformVisitTransformVisitInsurance