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

sub-job

Wildflower · Flow-Processing-LoadVisits

called by Flow-Processing

sub-job Wildflower/Flow-Processing-LoadVisits · db Wildflower_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-Processing-LoadVisits

23 tasks · Wildflower
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_processing_loadvisits__load_tempbatchvisit.sql
    ✨ Identifies upcoming visits requiring insurance eligibility verification based on service types, appointment dates, and previous coverage status.
    writes TempBatchVisitVisitEligServiceTypesVisitServiceTypes · reads DimensionMemberTempBatchVisitTransformVisitTransformVisitInsuranceTransformVisitInsuranceCoverageStatusVisitEligServiceTypesVisitServiceTypes
    ↳ feeds from Load TransformVisitInsuranceCoverageStatus, WildFlower Augment TempBatchVisit
  2. Augment Visit Deltasqlflow_processing_loadvisits__augment_visit_delta.sql
    ✨ Updates the visit delta table by adding records flagged as requiring new insurance eligibility lookups from the batch process.
    writes VisitDelta · reads TempBatchVisitVisitDelta
    ↳ feeds from Augment VisitDelta for ReprocessChangedConfig, Load TempBatchVisit, WildFlower Augment TempBatchVisit
  3. WildFlower Augment TempBatchVisitsqlflow_processing_loadvisits__wildflower_augment_tempbatchvisit.sql
    ✨ Augments the eligibility check batch with additional visits from specific source systems that lack recent or successful coverage verification.
    writes TempBatchVisit · reads DimensionMemberTempBatchVisitTransformVisitTransformVisitInsuranceTransformVisitInsuranceCoverageStatusVisitDelta
    ↳ feeds from Augment Visit Delta, Augment VisitDelta for ReprocessChangedConfig, Load TempBatchVisit, Load TransformVisitInsuranceCoverageStatus
  4. ReprocessChangedConfigurationsReprocessChangedConfigurations
    Identify and queue visits or accounts affected by configuration changes to ensure historical data reflects updated pricing or insurance rules.
    reprocess visits
  5. Augment VisitDelta for ReprocessChangedConfigsqlflow_processing_loadvisits__augment_visitdelta_for_reprocesschangedconfig.sql
    ✨ Updates insurance mappings for reprocessed visits and adds them to the delta table for downstream processing.
    writes VisitDeltaVisitKeyLookup · reads VisitDeltaVisitKeyLookup
    ↳ feeds from Augment Visit Delta
  6. LoadVisitBatchLoadVisitBatch
    Load scheduled visits and associated charges into the processing pipeline using custom SQL queries for pricing estimation and quote generation.
    writes QuoteBatchVisitBatch · reads FacilityPatientTransformVisitTransformVisitChargeTransformVisitInsuranceVisitVisitDelta
    ↳ feeds from Augment Visit Delta, Augment VisitDelta for ReprocessChangedConfig, Sync Visits and Quotes
    custom visit querycustom charge querycustom service type querycustom coverage queryadd zero charge
  7. load-custom-propertiessub-job
  8. AutoApplyBundlesToVisitBatchAutoApplyBundlesToVisitBatchdisabled
    Applies matching charge bundles to batch visits based on facility and insurance to ensure consistent pricing across service types.
    DISABLED
  9. CheckBenefitsflow
    Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.
    · reads TempBatchVisitVisitBatch
    ↳ feeds from Load TempBatchVisit, LoadVisitBatch, WildFlower Augment TempBatchVisit
    custom query
  10. 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
  11. AutoApplyBenefitsAutoApplyBenefits
    Populates insurance benefits like copays and deductibles on batch visits using data from eligibility verification transactions.
  12. CalculateVisitsflow
    Compute the good-faith estimate (CalculateVisits).
    · reads DimensionMemberVisitBatch
    ↳ feeds from LoadVisitBatch
    custom querycalculate chargesbatch mode
  13. AutoSendLettersAutoSendLetters
    Generates and sends patient cost estimate letters for visits in the batch table based on configured qualification and communication rules.
  14. LogVisitChangeEventsBatchLogVisitChangeEventsBatch
    Compare batch visits against production records to detect and log specific property changes for auditing and compliance tracking.
  15. Load TransformVisitInsuranceCoverageStatussqlflow_processing_loadvisits__load_transformvisitinsurancecoveragestatus.sql
    ✨ Loads insurance coverage status by calculating the latest eligibility transaction results for visits in the current batch.
    writes TempEligibilityStatsTransformVisitInsuranceCoverageStatus · reads TempEligibilityStatsTransformVisitInsuranceVisitBatch
    ↳ feeds from LoadVisitBatch
  16. ▶Load-CustomProperty-CoverageStatussub-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
  17. 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
  18. ExportBatchVisitEligibilityflowdisabled
    Push the batch to the app / export results.
    · reads EligibilityTxnVisitBatch
    custom querytable name=BatchEligibility_Resultsarchive table name=BatchEligibility_ResultsArchiveDISABLED
  19. SearchForInsuranceflowdisabled
    Find coverage for visits missing insurance.
    · reads EligibilityTxnBatch
    custom querytable name=InsuranceSearch_Resultbatch modeDISABLED
  20. WorkqueueAssignmentWorkqueueAssignment
    Assigns accounts or visits to workqueue stacks by evaluating matching criteria and updating item lists based on search terms.
  21. Generate-Reportsub-jobdisabled
  22. Load-Visit-Factsub-jobdisabled
  23. Update-Dashboard-Tablessub-jobdisabled