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

sub-job

JewishBoard · Load-Account-Transform-Tables-RevFind

Transforms-RevFind

called by RevFind-Daily-Processing

sub-job JewishBoard/Load-Account-Transform-Tables-RevFind · db JewishBoard_ProdMirror · updated 2026-06-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-Account-Transform-Tables-RevFind

14 tasks · JewishBoard
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. Fill AccountKeyMapsqlload_account_transform_tables_revfind__fill_accountkeymap.sql
    ✨ Maps patient and episode identifiers to unique account IDs to maintain consistent tracking across the data pipeline.
  2. Create AccountDeltasqlload_account_transform_tables_revfind__create_accountdelta.sql
    ✨ Identifies and flags accounts with recent billing or transaction updates to determine which records require processing in the current run.
  3. Load TransformPatientMergeSql
    writes TransformPatient · reads SourcePatient
    merge data source type=ThisDatabasetable name=TransformPatientmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  4. Load TransformLocationsqlload_account_transform_tables_revfind__load_transformlocation.sqldisabled
    ✨ Builds the location transformation table by mapping source locations to standardized addresses and place of service codes.
    writes TransformLocation · reads SourceLocationSourceLocationMap
  5. Load TransformProvidersqlload_account_transform_tables_revfind__load_transformprovider.sqldisabled
    ✨ Updates the provider transformation table with standardized names, credentials, and NPI identifiers from source systems.
    writes TransformProvider · reads SourceProvider
  6. Load TransformPayersqlload_account_transform_tables_revfind__load_transformpayer.sqldisabled
    ✨ Loads the payer transformation table with standardized insurance carrier names, plan types, and financial classifications.
    writes TransformPayer · reads SourcePayers
  7. Load TransformCharge (Initial, To Remove)sqlload_account_transform_tables_revfind__load_transformcharge_initial_to_remove.sqldisabled
    ✨ Loads and transforms charge-level data, including service details and insurance information, for accounts identified as having recent updates.
    writes TransformCharge · reads AccountDeltaAccountKeyMapSourceBillingTxHistorySourceLocationTransformChargemaster
  8. Merge TransformChargeMergeSql
    writes TransformCharge · reads AccountKeyMapSourceBillingTxHistorySourceChargeDetailsSourceInsuranceSourceLocationSourceTransactionPayAdjHistoryTransformChargemaster
    merge data source type=ThisDatabasetable name=TransformChargemerge mode=InsertUpdateHardDeletebulk copy timeout seconds=300bulk copy use table lock
  9. Load TransformTransactionsqlload_account_transform_tables_revfind__load_transformtransaction.sql
    ✨ Processes and categorizes financial transactions, such as payments and adjustments, while establishing their chronological order for each account.
    writes TransformTransaction · reads AccountDeltaAccountKeyMapAdjustmentCodeRollupSourceBillingTxHistorySourceTransactionPayAdjHistory
  10. (to delete once merge confirmed) Load TransformAccountsqlload_account_transform_tables_revfind__to_delete_once_merge_confirmed_load_transformaccount.sqldisabled
    ✨ Builds account-level summaries containing provider, facility, and patient identifiers to provide a high-level view of each encounter.
    writes TransformAccount · reads AccountKeyMapSourceBillingTxHistorySourceLocation
  11. Merge TransformAccountMergeSql
    writes TransformAccount · reads AccountKeyMapSourceBillingTxHistorySourceLocation
    merge data source type=ThisDatabasetable name=TransformAccountmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  12. Load TransformAccountInsurancesqlload_account_transform_tables_revfind__load_transformaccountinsurance.sqldisabled
    ✨ Loads insurance coverage details and coordination of benefits for each account to track payer information and member identifiers.
    writes TransformAccountInsurance · reads AccountKeyMapSourcePatientEncounterInsuranceTransformCharge
  13. Merge TransformAccountInsuranceMergeSql
    writes TransformAccountInsurance · reads AccountKeyMapSourcePatientEncounterInsuranceTransformCharge
    ↳ feeds from Merge TransformCharge
    merge data source type=ThisDatabasetable name=TransformAccountInsurancemerge mode=InsertUpdateHardDeletebulk copy timeout seconds=300bulk copy use table lock
  14. Load TransformChargeTransactionMeasuressqlload_account_transform_tables_revfind__load_transformchargetransactionmeasures.sql
    ✨ Aggregates transaction data into charge-level financial measures, calculating totals for payments, adjustments, and denials by insurance priority.
    writes TransformChargeTransactionMeasure · reads AccountDeltaTransformChargeTransformTransaction
    ↳ feeds from Load TransformTransaction, Merge TransformCharge