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

sub-job

OneGI · RevFind-Process-Accounts

Load Account-Level Tables

called by RevFind-Daily-Processing-ModMed, RevFind-Daily-Processing

sub-job OneGI/RevFind-Process-Accounts · db OneGI_ProdMirror · updated 2026-04-09

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 · OneGI
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 · 1↗Loads any Custom Properties used for business workflow use cases
    1. DeletedClaim - UpdateCustomPropertyFromQueryUpdateCustomPropertyFromQuery
      · reads AccountAccountKeyMapCustomPropertyMap
      entity=Accountcustom property key=DeletedClaimcustom query
  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 FacilitySourceFacilityGroupToTIN
      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 · 8↗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. GAVA - Anthem Routingsqlrevfind_process_post_load_account_routing__gava_anthem_routing.sqldisabled
      ✨ Routes Anthem and BCBS accounts to specific plan categories based on member ID prefixes and eligibility data.
      writes AccountDeltaRouting · reads AccountDeltaSourceAnthemBCBSEligibilityPrefixDataaccountfacilitytransformAccountInsurance
    3. GCM - Anthem TN Routingsqlrevfind_process_post_load_account_routing__gcm_anthem_tn_routing.sqldisabled
      ✨ Routes Tennessee Anthem accounts to specific provider networks based on member ID prefixes and plan names.
      writes AccountDeltaRouting · reads AccountDeltaFacilitySourceAnthemBCBSEligibilityPrefixDataaccounttransformAccountInsurance
    4. AccountDeltaRouting Mergesqlrevfind_process_post_load_account_routing__accountdeltarouting_merge.sqldisabled
      ✨ Updates account and insurance records with new routing information and appends relevant processing notes to the account history.
      writes AccountAccountInsuranceAccountNote · reads AccountDeltaRoutingAccountNoteaccountDelta
    5. Merge Account Label CommentsMergeSqldisabled
      writes AccountNote · reads AccountDeltaAccountDeltaRouting
      merge data source type=ThisDatabasetable name=AccountNotemerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    6. GAVA - UHC Physician Statussqlrevfind_process_post_load_account_routing__gava_uhc_physician_status.sql
      ✨ Flags UnitedHealthcare account charges with physician or non-physician status based on provider credentials for differential rate calculation.
      · reads AccountChargeCommonDataaccountaccountDeltaprovider
    7. GAVA - VA Region (Anthem + Aetna + Human Medicare)sqlrevfind_process_post_load_account_routing__gava_va_region_anthem_aetna_human_medicare.sql
      ✨ Appends geographic region codes to account charges for specific payers based on facility zip codes.
      · reads AccountChargeAccountDeltaaccountfacilitysourceVAFacilityRegion
    8. ALL UHC - Add UHC procedure category to code stringsqlrevfind_process_post_load_account_routing__all_uhc_add_uhc_procedure_category_to_code_string.sql
      ✨ Updates account charges by appending United Healthcare procedure categories to code strings for relevant insurance accounts.
      · reads AccountAccountChargeChargeTypeaccountDelta
  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