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

sub-job

NWDerm · Load-Visits

called by FHIR-Processing

sub-job NWDerm/Load-Visits · db NWDerm_ProdMirror · updated 2026-01-16

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

Load-Visits

22 tasks · NWDerm
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 TempBatchVisitsqlload_visits__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 Deltasqlload_visits__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 VisitDeltasqlload_visits__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. AutoApplyBundlesToVisitBatchAutoApplyBundlesToVisitBatchdisabled
    Applies matching charge bundles to batch visits based on facility and insurance to ensure consistent pricing across service types.
    DISABLED
  7. Augment TempBatchVisitsqlload_visits__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
  8. CheckBenefitsflowdisabled
    Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.
    · reads TempBatchVisitVisitBatch
    custom queryDISABLED
  9. Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.
    auto 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. LogVisitChangeEventsBatchLogVisitChangeEventsBatch
    Compare batch visits against production records to detect and log specific property changes for auditing and compliance tracking.
  14. Load TransformVisitInsuranceCoverageStatussqlload_visits__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
  15. 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
  16. 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
      Updates the visit fact table by refreshing records that have recent activity in payments, eligibility checks, or patient communications.
      writes VisitFact · reads EligibilityStatusMapEligibilityTxnPatientLetterPaymentTxnVisit