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

sub-job

MiddletownMedical · RevFind-Process-Accounts

Load Account-Level Tables

called by RevFind-Daily-Processing

sub-job MiddletownMedical/RevFind-Process-Accounts · db MiddletownMedical_ProdMirror · updated 2026-04-28

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

RevFind-Process-Accounts

8 tasks · MiddletownMedical
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. Augment AccountDeltaReprocessChangedConfigs
    reprocess accounts
  2. Augment AccountDelta ReprocessChangedConfigurationssqlrevfind_process_accounts__augment_accountdelta_reprocesschangedconfigurations.sql
    ✨ Flags specific patient accounts for reprocessing by adding them to the delta tracking table based on configuration changes.
    writes AccountDelta · reads AccountDeltaAccountsToReprocess
  3. Merge ChargeMeasuresMergeSql
    writes ChargeMeasures · reads TransformChargeTransformChargeTransactionMeasureTransformTransaction
    merge data source type=ThisDatabasetable name=ChargeMeasuresmerge mode=InsertUpdateHardDeletebulk copy timeout seconds=300bulk copy use table lock
  4. LoadAccountDataLoadAccountData
    Imports historical billing data from external systems into core account tables while preserving manual user modifications and application fields.
    · reads AccountChargeAccountDeltaAccountKeyMapChargeMeasuresChargeTypeFacilityInsuranceMapPatient
    ↳ feeds from Augment AccountDelta ReprocessChangedConfigurations, Merge ChargeMeasures
    custom account charge querycustom account querycustom account remit querycustom account insurance query
  5. RevFind-Process-CustomPropertiessub-job
    Loads any Custom Properties used for business workflow use cases
  6. ▶RevFind-Process-DimensionMemberssub-job · 10↗Loads all dimensions used for filtering and reporting
    1. Load Dimension MembersLoadDimensionMembers
      Synchronize facility, provider, and insurance metadata into the dimension member table to refresh dashboard filters and reporting categories.
      writes DimensionMember
      load insuranceload quote insuranceload eligibility insuranceload providerload bill type
    2. Merge DenialCategory DimensionMergeSql
      writes DimensionMember · reads AdjustmentCodeRollup
      merge data source type=ThisDatabasetable name=DimensionMembermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    3. Merge Place Of Service DimensionMergeSql
      writes DimensionMember · reads SourceECWEdiInvoiceSourceECWFacilities
      merge data source type=ThisDatabasetable name=DimensionMembermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    4. Merge Allowed Status DimensionMergeSql
      writes DimensionMember
      merge data source type=ThisDatabasetable name=DimensionMembermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    5. Merge Diagnosis Code DimensionMergeSql
      writes DimensionMember · reads DimensionMemberSourceECWEdiInvDiagnosis
      ↳ feeds from Load Dimension Members, Merge Allowed Status Dimension, Merge DenialCategory Dimension, Merge Facility Dimension, Merge Facility Group Dimension, Merge Facility Type Dimension, Merge Modifier Dimension, Merge Place Of Service Dimension, Merge ProviderType Dimension
      merge data source type=ThisDatabasetable name=DimensionMembermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    6. Merge Modifier DimensionMergeSql
      writes DimensionMember · reads ProcedureModifierTransformCharge
      merge data source type=ThisDatabasetable name=DimensionMembermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    7. Merge Facility Group DimensionMergeSql
      writes DimensionMember · reads Facility
      merge data source type=ThisDatabasetable name=DimensionMembermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    8. Merge Facility DimensionMergeSql
      writes DimensionMember · reads Facility
      merge data source type=ThisDatabasetable name=DimensionMembermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    9. Merge Facility Type DimensionMergeSql
      writes DimensionMember · reads Facility
      merge data source type=ThisDatabasetable name=DimensionMembermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    10. Merge ProviderType DimensionMergeSql
      writes DimensionMember · reads Provider
      merge data source type=ThisDatabasetable name=DimensionMembermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  7. ▶Revfind-Process-Post-Load-Account-Routingsub-job · 4↗Job to update Account and AccountInsurance tables prior to scoring for any custom rules needed to properly assign insurance and score (ie - Prefix Mapping, Age at Service mapping, etc.)
    1. Create AccountDeltaRouting Tablesqlrevfind_process_post_load_account_routing__create_accountdeltarouting_table.sql
      ✨ Builds a staging table to store insurance routing logic and comments for accounts requiring updates.
    2. Aetna/Aetna Medicare Routingsqlrevfind_process_post_load_account_routing__aetna_aetna_medicare_routing.sql
      ✨ Identifies Aetna accounts and assigns specific insurance keys based on member identification patterns for proper routing.
      writes AccountDeltaRouting · reads AccountAccountDeltaAccountInsuranceFacilityInsurancePatient
      ↳ feeds from AccountDeltaRouting Merge
    3. Anthem Medicaidsqlrevfind_process_post_load_account_routing__anthem_medicaid.sql
      ✨ Categorizes Anthem accounts into Medicaid or Medicare plans based on member ID prefixes to ensure accurate insurance mapping.
      writes AccountDeltaRouting · reads AccountAccountDeltaAccountInsuranceFacilityInsurancePatient
      ↳ feeds from AccountDeltaRouting Merge
    4. AccountDeltaRouting Mergesqlrevfind_process_post_load_account_routing__accountdeltarouting_merge.sql
      ✨ Updates account and insurance records with new routing information and appends relevant processing notes to the account history.
      writes AccountAccountInsuranceAccountNote · reads AccountDeltaRoutingAccountNoteaccountDelta
      ↳ feeds from Aetna/Aetna Medicare Routing, Anthem Medicaid
  8. ▶RevFind-Process-Scoringsub-job · 2↗Incrementally scores all accounts + medicare scenarios
    1. Score All AccountsBatchProcessAccounts
      writes AccountEstimate · reads QuoteBatchVisitBatch
      incrementalupdate dimensions
    2. Score Medicare Scenario AccountsBatchProcessAccounts
      writes AccountEstimate · reads QuoteBatchVisitBatch
      scenario insurance=Medicareincremental