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

sub-job

EugeneGI · Flow-MM-HL7-Processing-LoadVisits

called by Flow-MM-HL7-Processing

sub-job EugeneGI/Flow-MM-HL7-Processing-LoadVisits · db EugeneGI_ProdMirror · updated 2026-01-20

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-HL7-Processing-LoadVisits

22 tasks · EugeneGI
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. Load TempBatchVisitsqlflow_mm_hl7_processing_loadvisits__load_tempbatchvisit.sqldisabled
    ✨ Builds a temporary batch table to identify upcoming visits requiring initial or follow-up insurance eligibility and benefit verification.
    writes TempBatchVisitVisitEligServiceTypesVisitServiceTypes · reads DimensionMemberTempBatchVisitTransformVisitTransformVisitInsuranceTransformVisitInsuranceCoverageStatusVisitEligServiceTypesVisitServiceTypes
  2. Augment Visit Deltasqlflow_mm_hl7_processing_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 VisitDelta - ReprocessChangedConfigssqlflow_mm_hl7_processing_loadvisits__augment_visitdelta_reprocesschangedconfigs.sql
    ✨ Updates insurance mappings for queued visits and flags them in the delta table for downstream reprocessing.
    writes VisitDeltaVisitKeyLookup · reads TransformVisitVisitDeltaVisitKeyLookup
  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 DimensionMemberInsuranceMapPatientTransformVisitTransformVisitInsuranceVisitVisitDelta
    ↳ feeds from Augment VisitDelta - ReprocessChangedConfigs, Sync Visits and Quotes
    custom visit queryauto charge queryauto service type querycustom coverage queryadd zero charge
  6. Flow-MM-HL7-Processing-LoadCustomPropertiessub-jobdisabled
  7. AutoApplyBundlesToVisitBatchAutoApplyBundlesToVisitBatch
    Applies matching charge bundles to batch visits based on facility and insurance to ensure consistent pricing across service types.
  8. CheckBenefitsflow
    Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.
    auto query
  9. 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
  10. AutoApplyBenefitsAutoApplyBenefits
    Populates insurance benefits like copays and deductibles on batch visits using data from eligibility verification transactions.
  11. CalculateVisitsflow
    Compute the good-faith estimate (CalculateVisits).
    · reads DimensionMemberVisitBatch
    ↳ feeds from LoadVisitBatch
    custom querycalculate chargesbatch mode
  12. LogVisitChangeEventsBatchLogVisitChangeEventsBatch
    Compare batch visits against production records to detect and log specific property changes for auditing and compliance tracking.
  13. ExportBatchVisitEligibilityflow
    Push the batch to the app / export results.
    · reads EligibilityTxnvisitbatch
    ↳ feeds from LoadVisitBatch
    custom querytable name=BatchVisitEligibility
  14. Load TransformVisitInsuranceCoverageStatussqlflow_mm_hl7_processing_loadvisits__load_transformvisitinsurancecoveragestatus.sql
    ✨ Calculates and loads the latest insurance eligibility status and coverage details for visits in the current batch.
    writes TempEligibilityStatsTransformVisitInsuranceCoverageStatus · reads TempEligibilityStatsTransformVisitInsuranceVisitBatch
    ↳ feeds from LoadVisitBatch
  15. ▶Flow-MM-HL7-Processing-CustomPropertysub-job · 8↗
    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
    4. LoadCustomNotesCustomPropertyLoadCustomNotesCustomProperty
      · reads BundleNotesMappingHL7VisitVisitBatch
      entity=Visitcustom property key=CustomNotescustom querybatch mode
    5. LoadPriorAuthCustomPropertyLoadPriorAuthCustomProperty
      · reads CustomPropertyMapTransformVisitInsuranceVisitbatchsourcepriorauthdetails
      entity=Visitcustom property key=PriorAuthcustom querybatch mode
    6. LoadMedicaidRolloverCustomPropertyLoadMedicaidRolloverCustomProperty
      · reads CustomPropertyMapTransformVisitInsuranceVisitBatch
      entity=Visitcustom property key=MedicaidRollovercustom querybatch mode
    7. Load Has Active Medicaid/Medicare InsuranceUpdateCustomPropertyFromQuery
      · reads DimensionMemberTransformVisitInsuranceCoverageStatusVisitBatch
      entity=Visitcustom property key=HasActiveMedicaid/MedicareInsurancecustom querybatch mode
    8. Update HasMisMatchedMemberID Custom Property after recheckUpdateCustomPropertyFromQuery
      · reads BatchVisitEligibilityEligibilityTxnVisitBatch
      entity=Visitcustom property key=HasMismatchedMemberIDcustom querybatch mode
  16. 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
  17. ExportBatchVisitEligibilityflowdisabled
    Push the batch to the app / export results.
    · reads EligibilityTxnVisitBatch
    custom querytable name=BatchEligibility_Resultsarchive table name=BatchEligibility_ResultsArchiveDISABLED
  18. SearchForInsuranceflowdisabled
    Find coverage for visits missing insurance.
    · reads EligibilityTxnBatch
    custom querytable name=InsuranceSearch_Resultbatch modeDISABLED
  19. Generate-Reportsub-jobdisabled
  20. ▶Load-Visit-Factsub-job · 1↗
    1. Load VisitFactsqlload_visit_fact__load_visitfact.sql
      ✨ Refreshes the visit fact table by recalculating statuses, payment flags, and letter activity for visits with recent updates or transactions.
      writes VisitFact · reads EligibilityStatusMapEligibilityTxnPatientLetterPaymentTxnVisit
  21. ▶Update-Dashboard-Tablessub-job · 1↗
    1. UpdateDashboardTablesUpdateDashboardTables
      Regenerates optimized aggregate tables for all dashboard reports and updates their definitions to reflect the latest source data.
  22. LoadVisitBatchAutoSendsqlflow_mm_hl7_processing_loadvisits__loadvisitbatchautosend.sql
    ✨ Populates the auto-send queue with visit data to facilitate automated end-of-day processing and communication.
    writes VisitBatchAutoSend · reads VisitBatch
    ↳ feeds from LoadVisitBatch