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

Eligibility sweep · ClarityFlow pipeline

SeaRad · Daily-Processing-Eligibility

pipeline SeaRad/Daily-Processing-Eligibility · db SeaRad_ProdMirror · updated 2026-03-02
classification: flow · 7 Flow markers

trigger

How it's scheduled

Monthly sweep

A periodic re-check — eligibility and benefits drift between visits, so this re-verifies coverage on a monthly cadence rather than per-appointment.

Scheduled taskCadenceServerStateCoordination
\MDC\Monthly - Processing - SeaRadmonthly at 00:30prod-db-1enabledstandalone

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
Eligibility sweep
→
Eligibility & benefits
EligibilityBenefitsDiscovery
→
Estimate
Estimate
→
Letters
→
Work queue & sync
DashboardsSync

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

Daily-Processing-Eligibility

16 tasks · SeaRad
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 VisitDeltasqldaily_processing_eligibility__load_visitdelta.sql
    ✨ Builds a delta table of visit identifiers for appointments occurring within the current month to focus processing.
    writes VisitDelta · reads VisitDelta
  2. LoadVisitBatchLoadVisitBatch
    Load scheduled visits and associated charges into the processing pipeline using custom SQL queries for pricing estimation and quote generation.
    writes QuoteBatchVisitBatch · reads PatientTransformVisitTransformVisitChargeTransformVisitInsuranceVisitVisitDelta
    ↳ feeds from Load VisitDelta, Sync Visits and Quotes
    custom visit querycustom charge queryauto service type queryauto coverage queryadd zero charge
  3. Load TempBatchVisitsqldaily_processing_eligibility__load_tempbatchvisit.sql
    ✨ Loads a temporary batch table with visit, insurance, and eligibility details to prepare for insurance verification processing.
    · reads CommonDataDimensionMemberEligibilityTxnTransformVisitTransformVisitInsuranceVisitBatchVisitDeltastring_split
    ↳ feeds from Load VisitDelta, LoadVisitBatch
  4. CheckBenefitsflow
    Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.
    · reads TempBatchVisit
    custom query
  5. Re-Check Benefitsflowdisabled
    Verifies insurance eligibility and retrieves detailed benefits information for visits by making real-time API calls to insurance providers.
    · reads CommonDataEligibilityTxnTempBatchVisitTempVisitBatchInsertTime
    custom queryDISABLED
  6. AutoApplyBenefitsAutoApplyBenefits
    Populates insurance benefits like copays and deductibles on batch visits using data from eligibility verification transactions.
  7. CalculateVisitsflow
    Compute the good-faith estimate (CalculateVisits).
    · reads DimensionMemberVisitBatch
    ↳ feeds from LoadVisitBatch
    custom querycalculate chargesbatch mode
  8. Load TransformVisitInsuranceCoverageStatussqldaily_processing_eligibility__load_transformvisitinsurancecoveragestatus.sql
    ✨ Updates insurance coverage statuses for visits by evaluating the latest eligibility transaction results and active status flags.
  9. ▶Load-CustomProperty-CoverageStatussub-job · 2↗
    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
  10. 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
  11. ExportBatchVisitEligibilityflow
    Push the batch to the app / export results.
    · reads EligibilityTxnVisitBatch
    ↳ feeds from LoadVisitBatch
    custom querytable name=BatchEligibility_Resultsarchive table name=BatchEligibility_ResultsArchive
  12. SearchForInsuranceflowdisabled
    Find coverage for visits missing insurance.
    · reads EligibilityTxnBatch
    custom querytable name=InsuranceSearch_Resultbatch modeDISABLED
  13. ▶Generate-Reportsub-job · 4↗Generates the Daily Export report and pushed data into the Archive report for Load-Visits and Load-Visits-Reprocess
    1. Load TempEligibilityReportsqlgenerate_report__load_tempeligibilityreport.sql
      ✨ Builds a temporary table of eligibility results for specific visits and insurance plans to support reporting.
      writes TempEligibilityReport
    2. Load TempInsSearchResultssqlgenerate_report__load_tempinssearchresults.sql
      ✨ Loads active insurance search results into a temporary table to identify new coverage found during the eligibility process.
      writes TempInsSearchResults
    3. Generate Reportsqlgenerate_report__generate_report.sql
      ✨ Generates a comprehensive batch eligibility report by consolidating patient visit data with primary, secondary, and tertiary insurance verification results.
      writes BatchEligibility_ResultsReport
    4. Archive Reportsqlgenerate_report__archive_report.sql
      ✨ Updates the eligibility report archive by replacing existing visit records with the most recent verification results.
      writes BatchEligibility_ResultsReportArchive · reads BatchEligibility_ResultsReport
      ↳ feeds from Generate Report
  14. Custom PropertiesUpdateVisitCustomPropertyFromQuery
    · reads BatchEligibility_ResultsReportCustomPropertyMap
    ↳ feeds from Sync Visits and Quotes
    auto visit update custom property query
  15. ▶Load-Visit-Factsub-job · 1↗
    1. Load VisitFactsqlload_visit_fact__load_visitfact.sql
      ✨ Updates the visit fact table by refreshing records with recent activity, including payments, eligibility checks, and patient communications.
      writes VisitFact · reads EligibilityStatusMapEligibilityTxnPatientLetterPaymentTxnVisit
  16. ▶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.

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
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_benefits
Auto-apply parsed benefits to visits