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

FHIR feed · ClarityFlow pipeline

MannEye · Flow-FHIR-Processing

Overall Processing job for FHIR pipeline

pipeline MannEye/Flow-FHIR-Processing · db MannEye_ProdMirror · updated 2025-09-17
classification: flow · 10 Flow markers

trigger

How it's scheduled

Real-time loop — every 10 min (~144×/day)

New appointments land continuously on the FHIR feed. Front-of-house work is time-boxed — the estimate and letter have to reach the patient before the visit — so the pipeline polls every 10 minutes to check eligibility, price the good-faith estimate, and send the patient letter within minutes of an appointment being booked, rather than waiting for an overnight batch.

Scheduled taskCadenceServerStateCoordination
\MDC\FHIR - Processing - MannEyeevery 10 min (from 00:01)prod-db-1disabledstandalone

shape

Against the canonical Flow spine

Every Flow pipeline is a variation on one shape. Lit stages are the ones this pipeline runs; the labels match the capability lens.

Ingest
FHIR feed
→
Eligibility & benefits
EligibilityBenefitsDiscovery
→
Estimate
BundlesEstimate
→
Letters
Letters
→
Work queue & sync
Work queueDashboardsSync

computed concepts · from the SQL

What it computes

Business concepts mined from this pipeline's SQL text — the meaning behind the typed steps. Each links to the concept lens (who else computes it).

Coverage status

task tree

What the pipeline 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).

flow

Flow-FHIR-Processing

8 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. unnamed stepunknown
  2. FHIRProcessBatchsqlflow_fhir_processing__fhirprocessbatch.sql
    ✨ Identifies new FHIR data batches and flags specific appointment types for incremental processing in the visit delta table.
    writes FHIRProcessBatchVisitDelta · reads FHIRIncomingSourceAppointmentFHIRProcessBatchProcessLog
  3. ▶Flow-Transform-Visitssub-job · 5↗FHIR Transformation Layer
    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
  4. ▶Flow-Process-LoadEntitiessub-job · 3↗Load Facility, Provider
    1. Load Facility Mapping fileProcessFiledisabled
      writes ImportFacilityMapSourceFacilityMap
      file path={SourceDataFolder}\Facility Mapping.csvbase table name=FacilityMaprow terminator=Newlinecolumn separator=CommaDISABLED
    2. Load FacilityLoadEntities
      writes Facility · reads FHIRActorFHIRProcessBatchFacilitySourceFacilityMap
      entity type=Facilitycustom query
    3. Load Providersqlflow_process_loadentities__load_provider.sqldisabled
      ✨ Loads provider details into the master provider table using the latest physician information from HL7 visit messages.
      writes Provider · reads HL7Visit
  5. ▶Flow-Process-LoadDimensionMemberssub-job · 12↗
    1. Load Insurance Dimensionsqlflow_process_loaddimensionmembers__load_insurance_dimension.sqldisabled
      ✨ Populates the insurance dimension with unique carrier keys to enable filtering and analysis by payer.
      writes DimensionMember · reads Insurance
    2. Load EligibilityInsurance Dimensionsqlflow_process_loaddimensionmembers__load_eligibilityinsurance_dimension.sqldisabled
      ✨ Loads insurance members that support electronic eligibility and benefits verification via API integration.
      writes DimensionMember · reads DimensionMemberInsurance
    3. Load QuoteInsurance Dimensionsqlflow_process_loaddimensionmembers__load_quoteinsurance_dimension.sqldisabled
      ✨ Builds a dimension of insurance providers associated with active contracts to facilitate accurate patient cost estimates.
      writes DimensionMember · reads ContractMapInsurance
    4. LoadInsuranceDimensionMembersLoadInsuranceDimensionMembers
      Synchronize insurance-specific dimension members from the insurance table to update contract and eligibility filtering options across the application.
      writes DimensionMember
      load insuranceload quote insuranceload eligibility insurance
    5. Load Time Dimensionssqlflow_process_loaddimensionmembers__load_time_dimensions.sql
      ✨ Builds and updates time-based dimensions including days, months, and years derived from appointment schedule dates.
      writes DimensionMember · reads FHIRIncomingSourceAppointment
    6. Load VisitStatus Dimensionsqlflow_process_loaddimensionmembers__load_visitstatus_dimension.sql
      ✨ Builds the visit status dimension by extracting unique appointment statuses from transformed visit data.
      writes DimensionMember · reads TransformVisit
    7. Load Provider Dimensionsqlflow_process_loaddimensionmembers__load_provider_dimension.sql
      ✨ Updates the provider dimension with the latest provider names and IDs from incoming appointment records.
      writes DimensionMember · reads FHIRIncomingSourceAppointment
    8. Load Facility Dimensionssqlflow_process_loaddimensionmembers__load_facility_dimensions.sql
      ✨ Loads facility dimension members and their parent groups from the facility configuration data.
      writes DimensionMember · reads Facility
    9. Load FacilityType Dimensionssqlflow_process_loaddimensionmembers__load_facilitytype_dimensions.sql
      ✨ Loads facility type dimension members from facility records to enable standardized categorization across the revenue cycle pipeline.
      writes DimensionMember · reads Facility
    10. Load FacilityGroup Dimensionssqlflow_process_loaddimensionmembers__load_facilitygroup_dimensions.sql
      ✨ Builds the facility group dimension by identifying unique parent groups from facility dimension records.
      writes DimensionMember · reads DimensionMember
      ↳ feeds from Load Facility Dimensions, Load FacilityType Dimensions, Load Provider Dimension, Load State Dimensions, Load Time Dimensions, Load VisitStatus Dimension, Load VisitType Dimensions, LoadInsuranceDimensionMembers
    11. Load VisitType Dimensionssqlflow_process_loaddimensionmembers__load_visittype_dimensions.sql
      ✨ Builds the visit type dimension using the most recent appointment types found in incoming scheduling data.
      writes DimensionMember · reads FHIRIncomingSourceAppointment
    12. Load State Dimensionssqlflow_process_loaddimensionmembers__load_state_dimensions.sql
      ✨ Loads unique state codes from facility records into the state dimension for geographic reporting.
      writes DimensionMember · reads Facility
  6. ▶Flow-Process-LoadVisitssub-job · 23↗
    1. Load TempBatchVisitsqlflow_process_loadvisits__load_tempbatchvisit.sqldisabled
      ✨ Flags upcoming visits for insurance eligibility checks based on service types, coverage status, and appointment lead times.
      writes TempBatchVisitVisitEligServiceTypesVisitServiceTypes · reads DimensionMemberTempBatchVisitTransformVisitTransformVisitInsTransformVisitInsuranceTransformVisitInsuranceCoverageStatusVisitEligServiceTypesVisitServiceTypes
    2. Augment Visit Deltasqlflow_process_loadvisits__augment_visit_delta.sqldisabled
      ✨ Updates the visit delta table by adding records flagged as requiring new insurance eligibility lookups from the batch process.
      writes VisitDelta · reads TempBatchVisitVisitDelta
    3. ReprocessChangedConfigurationsReprocessChangedConfigurations
      Identify and queue visits or accounts affected by configuration changes to ensure historical data reflects updated pricing or insurance rules.
      reprocess visits
    4. Augment VisitDeltasqlflow_process_loadvisits__augment_visitdelta.sql
      ✨ Updates insurance mappings for reprocessed visits and adds them to the delta table for downstream processing.
      writes VisitDeltaVisitKeyLookup · reads VisitDeltaVisitKeyLookup
    5. LoadVisitBatchLoadVisitBatch
      Load scheduled visits and associated charges into the processing pipeline using custom SQL queries for pricing estimation and quote generation.
      writes QuoteBatchVisitBatch · reads PatientTransformVisitTransformVisitInsuranceVisitVisitDelta
      ↳ feeds from Augment VisitDelta, Sync Visits and Quotes
      custom visit queryauto charge querycustom service type querycustom coverage queryadd zero charge
    6. load-custom-propertiessub-jobdisabled
    7. AutoApplyBundlesToVisitBatchAutoApplyBundlesToVisitBatch
      Applies matching charge bundles to batch visits based on facility and insurance to ensure consistent pricing across service types.
    8. Augment TempBatchVisitsqlflow_process_loadvisits__augment_tempbatchvisit.sqldisabled
      ✨ Flags visits for eligibility rechecks based on appointment lead time and previous transaction status to ensure coverage is verified.
      writes TempBatchVisit · reads DimensionMemberEligibilityTxnTempBatchVisitTransformVisitTransformVisitInsuranceTransformVisitInsuranceCoverageStatusVisitVisitBatch
    9. CheckBenefitsflow
      Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.
      auto query
    10. CheckBenefits OLDflowdisabled
      Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.
      · reads TempBatchVisitVisitBatch
      custom queryDISABLED
    11. Re-Check Benefitsflowdisabled
      Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.
      · reads EligibilityStatusMapEligibilityTxnTempBatchVisitVisitBatch
      custom queryDISABLED
    12. AutoApplyBenefitsAutoApplyBenefits
      Populates insurance benefits like copays and deductibles on batch visits using data from eligibility verification transactions.
    13. CalculateVisitsflow
      Compute the good-faith estimate (CalculateVisits).
      · reads DimensionMemberVisitBatch
      ↳ feeds from LoadVisitBatch
      custom querycalculate chargesbatch mode
    14. AutoSendLettersAutoSendLetters
      Generates and sends patient cost estimate letters for visits in the batch table based on configured qualification and communication rules.
    15. LogVisitChangeEventsBatchLogVisitChangeEventsBatch
      Compare batch visits against production records to detect and log specific property changes for auditing and compliance tracking.
    16. Load TransformVisitInsuranceCoverageStatussqlflow_process_loadvisits__load_transformvisitinsurancecoveragestatus.sql
      ✨ Updates insurance coverage statuses by analyzing recent eligibility transactions and mapping results to standardized active or inactive states.
      writes TempEligibilityStatsTransformVisitInsuranceCoverageStatus · reads TempEligibilityStatsTransformVisitInsuranceVisitBatch
      ↳ feeds from LoadVisitBatch
    17. ▶Flow-Process-CustomPropertysub-job · 3↗
      1. Load Primary Coverage StatusUpdateCustomPropertyFromQuery
        · reads TransformVisitInsuranceCoverageStatusVisitBatch
        entity=Visitcustom property key=PrimaryCoverageStatuscustom querybatch mode
      2. Load Secondary Coverage StatusUpdateCustomPropertyFromQuery
        · reads TransformVisitInsuranceCoverageStatusVisitBatch
        entity=Visitcustom property key=SecondaryCoverageStatuscustom querybatch mode
      3. Load Tertiary Coverage StatusUpdateCustomPropertyFromQuery
        · reads TransformVisitInsuranceCoverageStatusVisitBatch
        entity=Visitcustom property key=TertiaryCoverageStatuscustom querybatch mode
    18. Sync Visits and QuotesSyncBatch
      Synchronizes processed data from batch staging tables to production tables, updating visits, quotes, and custom property mappings.
      writes CustomPropertyMapQuoteVisitVisitChangeEvent · reads CustomPropertyMapBatchQuoteBatchVisitBatchVisitChangeEventBatch
      ↳ feeds from LoadVisitBatch
      sync quotesync visitsync custom property mapsync visit change event
    19. ExportBatchVisitEligibilityflowdisabled
      Push the batch to the app / export results.
      · reads EligibilityTxnVisitBatch
      custom querytable name=BatchEligibility_Resultsarchive table name=BatchEligibility_ResultsArchiveDISABLED
    20. SearchForInsuranceflowdisabled
      Find coverage for visits missing insurance.
      · reads EligibilityTxnBatch
      custom querytable name=InsuranceSearch_Resultbatch modeDISABLED
    21. Generate-Reportsub-jobdisabled
    22. ▶Flow-Process-LoadVisitFactsub-job · 1↗
      1. Load VisitFactsqlflow_process_loadvisitfact__load_visitfact.sql
        ✨ Updates visit-level facts and metrics by refreshing data for visits with recent activity in payments, eligibility, or communications.
        writes VisitFactVisitFactDelta · reads EligibilityStatusMapEligibilityTxnPatientLetterPaymentTxnVisitVisitFactDelta
    23. Update-Dashboard-Tablessub-jobdisabled
  7. WorkqueueAssignmentWorkqueueAssignment
    Assigns accounts or visits to workqueue stacks by evaluating matching criteria and updating item lists based on search terms.
  8. UpdateDashboardTablesUpdateDashboardTables
    Regenerates optimized aggregate tables for all dashboard reports and updates their definitions to reflect the latest source data.

markers

Why it classified as flow

Front-of-house actions found anywhere in the tree (including nested sub-jobs).

CalculateVisits
Compute the good-faith estimate
CheckBenefits
Real-time eligibility (270/271) benefit lookup
CheckBenefits OLD
ClarityFlow front-of-house step
ExportBatchVisitEligibility
Export eligibility results
Load TransformVisitInsuranceCoverageStatus
ClarityFlow front-of-house step
LoadVisitBatch
ClarityFlow front-of-house step
SearchForInsurance
Insurance discovery for visits missing coverage
auto_apply_bundles
Apply procedure bundles for the estimate
auto_benefits
Auto-apply parsed benefits to visits
auto_send_letters
Send GFE / patient letters