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

Batch / file feed · RevFind pipeline

StrideCare · RevFind-Daily-Processing-Accounts-33143

Process Athena Accounts

pipeline StrideCare/RevFind-Daily-Processing-Accounts-33143 · db StrideCare_ProdMirror · updated 2026-06-09
classification: revfind · 0 Flow markers

trigger

How it's scheduled

Daily batch — once at 02:00

The Batch / file feed arrives as a scheduled drop, so one overnight pass is enough: it ingests the day's file and works the whole batch to process the visits. A tighter loop would just re-scan the same file.

Scheduled taskCadenceServerStateCoordination
\MDC\Daily - Processing - StrideCaredaily at 02:00prod-db-1enabledstandalone

shape

The RevFind back-office spine

RevFind pipelines share a back-office shape: ingest → load accounts → reconcile remits → model contracts → surface underpayments. Lit stages are the ones this pipeline runs.

Ingest
Batch / file feed
→
Accounts / AR
ACCT
→
Remit (835)
→
Contract model
CTR
→
Payer rules
→
Work queue & sync
Sync

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).

Fee schedule / contractDenial / underpaymentCPT / procedure logic

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).

revfind

RevFind-Daily-Processing-Accounts-33143

9 tasks · StrideCare
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. ▶RevFind-Source-LoadAthenaData-33143sub-job · 28↗
    1. Merge SourceClaimMergeSql
      writes SourceClaim_33143 · reads CLAIM
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceClaim_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    2. Merge SourceClinicalEncounterMergeSql
      writes SourceClinicalEncounter_33143 · reads CLINICALENCOUNTER
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceClinicalEncounter_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    3. Merge SourceAppointmentMergeSql
      writes SourceAppointment_33143 · reads APPOINTMENTCLAIM
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceAppointment_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    4. Merge SourceTransactionMergeSql
      writes SourceTransaction_33143 · reads CLAIMTRANSACTION
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceTransaction_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    5. Merge SourceTransactionChargeMergeSqldisabled
      writes SourceTransactionCharge_33143 · reads SOURCETRANSACTION_33143
      merge data source type=ThisDatabasetable name=SourceTransactionCharge_33143merge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    6. Merge SourceTransationPaymentMergeSqldisabled
      writes SourceTransactionPayment_33143 · reads SOURCETRANSACTION_33143
      merge data source type=ThisDatabasetable name=SourceTransactionPayment_33143merge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    7. Merge SourceTransactionAdjustmentMergeSqldisabled
      writes SourceTransactionAdjustment_33143 · reads SOURCETRANSACTION_33143
      merge data source type=ThisDatabasetable name=SourceTransactionAdjustment_33143merge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    8. Merge SourceTransactionTransferMergeSqldisabled
      writes SourceTransactionTransfer_33143 · reads SOURCETRANSACTION_33143
      merge data source type=ThisDatabasetable name=SourceTransactionTransfer_33143merge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    9. Merge SourceERABatchMergeSql
      writes SourceERABatch_33143 · reads ERABATCH
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceERABatch_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    10. Merge SourceERARecordMergeSql
      writes SourceERARecord_33143 · reads ERARECORD
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceERARecord_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    11. Merge SourceERADetailMergeSql
      writes SourceERADetail_33143 · reads ERADETAILERARECORD
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceERADetail_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    12. Merge SourceERAKickMergeSql
      writes SourceERAKick_33143 · reads ERAKICK
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceERAKick_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    13. Merge SourceClaimNoteMergeSqldisabled
      writes SourceClaimNote_33143 · reads CLAIMNOTE
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceClaimNote_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    14. Merge SourceDenialClaimNoteMergeSqldisabled
      writes SourceDenialClaimNote_33143 · reads DENIALCLAIMNOTE
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceDenialClaimNote_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    15. Merge SourcePatientMergeSql
      writes SourcePatient_33143 · reads CLAIMPATIENT
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourcePatient_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    16. Merge SourcePayerMergeSql
      writes SourcePayer_33143 · reads INSURANCEPACKAGEPAYER
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourcePayer_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    17. Merge SourcePatientInsuranceMergeSql
      writes SourcePatientInsurance_33143 · reads CLAIMPATIENTINSURANCE
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourcePatientInsurance_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    18. Merge SourceProviderMergeSql
      writes SourceProvider_33143 · reads PROVIDER
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceProvider_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    19. Merge SourceDepartmentMergeSql
      writes SourceDepartment_33143 · reads DEPARTMENT
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceDepartment_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    20. Merge SourceAppointmentTypeMergeSql
      writes SourceAppointmentType_33143 · reads APPOINTMENTTYPE
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceAppointmentType_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    21. Merge SourceFeeScheduleProcedureMergeSql
      writes SourceFeeScheduleProcedure_33143 · reads FEESCHEDULEPROCEDURE
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceFeeScheduleProcedure_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    22. Merge SourceProcedureCodeMergeSql
      writes SourceProcedureCode_33143 · reads PROCEDURECODE
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceProcedureCode_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    23. Merge SourceFeeScheduleMergeSql
      writes SourceFeeSchedule_33143 · reads FEESCHEDULE
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceFeeSchedule_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    24. Merge SourceProcedureCodeModifierMergeSql
      writes SourceProcedureCodeModifier_33143 · reads PROCEDURECODEMODIFIER
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceProcedureCodeModifier_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    25. Merge SourceFeeScheduleDepartmentMergeSql
      writes SourceFeeScheduleDepartment_33143 · reads FEESCHEDULEDEPARTMENT
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceFeeScheduleDepartment_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    26. Merge FEESCHEDALLOWABLECATEGORYMergeSql
      writes SourceFeeSchedAllowableCategory_33143 · reads FEESCHEDALLOWABLECATEGORY
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceFeeSchedAllowableCategory_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    27. Merge SourceTimesheetEntryTransactionMergeSql
      writes SourceTimesheetEntryTransaction_33143 · reads TIMESHEETENTRYTIMESHEETENTRYTRANSACTION
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceTimesheetEntryTransaction_33143merge mode=InsertUpdatebulk copy timeout seconds=300
    28. Merge SourceCustomDemographicsMergeSql
      writes SourceCustomDemographics_33143 · reads CUSTOMDEMOGRAPHICS
      merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceCustomDemographics_33143merge mode=InsertUpdatebulk copy timeout seconds=300
  2. ▶RevFind-Transform-LoadInsuranceMapsub-job · 3↗
    1. Load-InsuranceMapLoad-InsuranceMapdisabled
      writes InsuranceMap · reads InsuranceMapSourcePayer
      entity type=InsuranceMapauto querykey prefix=IMDISABLED
    2. Load-InsuranceMap-With-Import-TableLoad-InsuranceMap-With-Import-Tabledisabled
      writes InsuranceMap · reads InsuranceMapSourceInsuranceMapImportSourcePayer
      entity type=InsuranceMapcustom querykey prefix=IMDISABLED
    3. Load-InsuranceMap (InsPackageID)LoadEntities
      writes InsuranceMap · reads InsuranceMapSourcePayerSourcePayer_33143
      entity type=InsuranceMapcustom querykey prefix=IM
  3. ▶RevFind-Transform-ChargeTypesub-job · 12↗Load the Charge Types from ChargeMaster + CPT Crosswalk
    1. Merge TransformChargeMasterMergeSqldisabled
      writes TransformChargeMaster · reads SourceFeeScheduleDepartmentsourcefeeschedulesourcefeescheduleprocedure
      merge data source type=ThisDatabasetable name=TransformChargeMastermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    2. Merge ChargeTypeMergeSql
      writes ChargeType · reads ChargeTypeSourceProcedureCode_33143
      merge data source type=ThisDatabasetable name=ChargeTypemerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    3. Merge ProcedureCode DimensionMemberMergeSql
      writes DimensionMember · reads ChargeTypeProcedureCode
      ↳ feeds from Merge ChargeType
      merge data source type=ThisDatabasetable name=DimensionMembermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    4. Merge ChargeType into DimensionMemberMergeSql
      writes DimensionMember · reads ChargeType
      ↳ feeds from Merge ChargeType
      merge data source type=ThisDatabasetable name=DimensionMembermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
    5. Update ChargeMaster SchedulesUpdateFeePricing
      writes FeePricingRecord · reads SourceChargeMaster
      schedule insert type=Replaceschedule type=Chargessource table=SourceChargeMaster
    6. Load Charges SchedulesLoadFeeSchedules
      Generate time-based fee schedules from pricing records to establish effective date ranges for facility and insurance billing combinations.
      writes ScheduleScheduleMap · reads FeePricingRecord
      ↳ feeds from Update ChargeMaster Schedules
    7. Load ProcedureCategory into DimensionMembersqlrevfind_transform_chargetype__load_procedurecategory_into_dimensionmember.sql
      ✨ Builds procedure category dimension members by extracting parent groupings from existing procedure codes to support hierarchical reporting.
      writes DimensionMember · reads DimensionMember
      ↳ feeds from Merge ChargeType into DimensionMember, Merge ProcedureCode DimensionMember
    8. Load TempFeeScheduleMapsqlrevfind_transform_chargetype__load_tempfeeschedulemap.sql
      ✨ Builds a temporary mapping table that identifies and categorizes fee schedules as either self-pay or chargemaster for specific departments.
      writes TempFeeScheduleMap · reads SourceFeeSchedAllowableCategory_33143SourceFeeScheduleDepartment_33143SourceFeeSchedule_33143SourcePayer_33143
    9. Load Chargemaster into ScheduleMap/FeeScheduleRecordsqlrevfind_transform_chargetype__load_chargemaster_into_schedulemap_feeschedulerecord.sql
      ✨ Loads chargemaster rates and facility mappings into the system to define standard billing amounts for medical procedures.
      writes FeeScheduleRecordScheduleMap · reads SourceFeeScheduleProcedure_33143TempFeeScheduleMap
      ↳ feeds from Load TempFeeScheduleMap
    10. Load Self-Pay Fees into ScheduleMap/FeeScheduleRecordsqlrevfind_transform_chargetype__load_self_pay_fees_into_schedulemap_feeschedulerecord.sql
      ✨ Loads self-pay fee schedules and facility mappings to establish fixed pricing for patients without insurance coverage.
      writes FeeScheduleRecordScheduleMap · reads SourceFeeScheduleProcedure_33143TempFeeScheduleMap
      ↳ feeds from Load TempFeeScheduleMap
    11. LoadEntitiesFromQuery (Chargemaster schedules)LoadEntities
      writes Schedule · reads TempFeeScheduleMap
      ↳ feeds from Load TempFeeScheduleMap
      entity type=Scheduleauto querykey prefix=S
    12. LoadEntitiesFromQuery (Selfpay schedules)LoadEntities
      writes Schedule · reads TempFeeScheduleMap
      ↳ feeds from Load TempFeeScheduleMap
      entity type=Scheduleauto querykey prefix=S
  4. ▶RevFind-Transform-Accountssub-job · 11↗Athena Transforms
    1. Create AccountDeltasqlrevfind_transform_accounts__create_accountdelta.sql
      ✨ Builds a delta table of modified accounts, encounters, and claims to identify records requiring incremental processing in the pipeline.
      writes AccountDelta · reads AccountDeltaAccountDeltaDateSourceAppointmentSourceClaimSourceClinicalEncounterSourceERADetailSourcePatientInsuranceSourceTransaction
      ↳ feeds from Update AccountDeltaDate
    2. Load TransformTransaction - Updated for Claims sans Visitssqlrevfind_transform_accounts__load_transformtransaction_updated_for_claims_sans_visits.sql
      ✨ Updates transaction records by refreshing financial data, including payments and adjustments, for accounts identified in the incremental delta.
    3. Load TransformRemitAdjustment - Updated for Claims sans Visitssqlrevfind_transform_accounts__load_transformremitadjustment_updated_for_claims_sans_visits.sql
      ✨ Loads detailed remittance adjustment data from electronic remittance advice records for accounts requiring updates in the current pipeline run.
      writes TransformRemitAdjustment · reads AccountDeltaAdjustmentCodeRollupSourceClaimSourceERABatchSourceERADetailSourceERAKickSourceERARecordSourcePatientInsurance
      ↳ feeds from Create AccountDelta
    4. Load TransformCharge - Updated for Claims sans Visitssqlrevfind_transform_accounts__load_transformcharge_updated_for_claims_sans_visits.sql
      ✨ Updates charge-level details, including procedure codes, modifiers, and diagnosis information, for accounts identified in the incremental delta.
    5. Load TransformAccount - Updated for Claims sans Visitssqlrevfind_transform_accounts__load_transformaccount_updated_for_claims_sans_visits.sql
      ✨ Refreshes core account and encounter data, including balances and service dates, for records identified in the incremental delta.
      writes TransformAccount · reads AccountDeltaSourceClaimSourceClinicalEncounterSourceDepartmentSourcePatientInsuranceSourceProvider
      ↳ feeds from Create AccountDelta
    6. Load TransformRemitAdjustmentAggregatesqlrevfind_transform_accounts__load_transformremitadjustmentaggregate.sql
      ✨ Aggregates remittance adjustment data to calculate total contract, patient, and denial amounts at the charge level for updated encounters.
      writes TransformRemitAdjustmentAggregate · reads AccountDeltaTransformChargeTransformRemitAdjustment
      ↳ feeds from Create AccountDelta, Load TransformRemitAdjustment - Updated for Claims sans Visits
    7. Load TransformChargeTransactionMeasuressqlrevfind_transform_accounts__load_transformchargetransactionmeasures.sql
      ✨ Calculates summary financial measures by combining transaction and remittance data to report payments, adjustments, and denials per charge.
      writes TransformChargeTransactionMeasure · reads AccountDeltaTransformChargeTransformRemitAdjustmentAggregateTransformTransaction
      ↳ feeds from Create AccountDelta, Load TransformRemitAdjustmentAggregate
    8. Load TransformPatientsqlrevfind_transform_accounts__load_transformpatient.sql
      ✨ Updates and maintains patient demographic information in the transformation layer to ensure accurate patient identification.
      writes TransformPatient · reads SourcePatient
    9. Load TransformPatientInsurancesqlrevfind_transform_accounts__load_transformpatientinsurance.sql
      ✨ Synchronizes patient insurance coverage details and coordination of benefits using a merge process to maintain current policy information.
      writes TransformPatientInsurance · reads InsuranceMapSourcePatientInsuranceSourcePayer
    10. TransformAccountInsurance - ExecuteMergeSqlMergeSql
      writes TransformAccountInsurance · reads AccountDeltaInsuranceMapSourcePatientInsuranceSourcePayerTransformAccount
      ↳ feeds from Create AccountDelta, Load TransformAccount - Updated for Claims sans Visits
      merge data source type=ThisDatabasetable name=TransformAccountInsurancemerge mode=InsertUpdateHardDeletebulk copy timeout seconds=300bulk copy use table lock
    11. Update AccountDeltaDatesqlrevfind_transform_accounts__update_accountdeltadate.sql
      ✨ Updates the reference timestamp to track the last time account changes were processed in the pipeline.
      writes AccountDeltaDate
  5. ▶RevFind-Process-PatientsEntitysub-job · 1↗
    1. Execute LoadPatientsLoadPatients
      Upsert patient records into the patient dimension.
      · reads PatientTransformPatient
      custom patient query
  6. ▶RevFind-Process-LoadEntitiessub-job · 2↗Load Facility, Provider
    1. Load FacilityLoadEntities
      writes Facility · reads FacilitySourceDepartment_33143
      entity type=Facilitycustom query
    2. Load Providersqlrevfind_process_loadentities__load_provider.sql
      ✨ Loads and updates provider entity details including names, types, NPIs, and taxonomy codes from the source system.
      writes Provider · reads SourceProvider_33143
  7. ▶RevFind-Process-DimensionMemberssub-job · 1↗
    1. Load Modifier Dimensionsqlrevfind_process_dimensionmembers__load_modifier_dimension.sql
      ✨ Builds and updates the Modifier dimension using procedure code modifiers and descriptions from the source system.
      writes DIMENSIONMEMBER · reads SOURCEPROCEDURECODEMODIFIER
  8. ▶RevFind-Process-LoadAccountsub-job · 8↗Load Account-Level Tables
    1. Augment AccountDeltaReprocessChangedConfigs
      reprocess accounts
    2. Augment AccountDelta ReprocessChangedConfigurationssqlrevfind_process_loadaccount__augment_accountdelta_reprocesschangedconfigurations.sql
      ✨ Adds accounts requiring reprocessing due to configuration changes into the account delta table for downstream processing.
      writes AccountDelta · reads AccountDeltaAccountsToReprocessTransformAccount
    3. Load ChargeMeasuressqlrevfind_process_loadaccount__load_chargemeasures.sql
      ✨ Calculates and loads financial metrics including payments, adjustments, and denials for account charges into the charge measures table.
      writes ChargeMeasures · reads AccountDeltaTransformChargeTransformChargeTransactionMeasure
      ↳ feeds from Augment AccountDelta ReprocessChangedConfigurations
    4. LoadAccountDataLoadAccountData
      Imports historical billing data from external systems into core account tables while preserving manual user modifications and application fields.
      · reads AccountChargeAccountDeltaChargeMeasuresChargeTypeInsuranceMapPatientProviderSourcePatientInsurance
      ↳ feeds from Augment AccountDelta ReprocessChangedConfigurations, Load ChargeMeasures
      custom account charge queryauto account querycustom account remit querycustom account insurance query
    5. ▶RevFind-Process-LoadCustomPropertiessub-job · 3↗
      1. Load Claim ID Custom PropertyUpdateCustomPropertyFromQuery
        · reads AccountDeltaTransformAccount
        entity=Accountcustom property key=CustomProperty-[id]auto querybatch mode
      2. Load Plan NameUpdateCustomPropertyFromQuery
        · reads AccountDeltaTransformAccount
        entity=Accountcustom property key=Plan Nameauto querybatch mode
      3. SyncBatchSyncBatch
        Synchronizes processed data from batch staging tables to production tables, updating visits, quotes, and custom property mappings.
        writes CustomPropertyMap · reads CustomPropertyMapBatch
        sync custom property map
    6. ▶RevFind-Process-LoadDimensionMemberssub-job · 13↗
      1. LoadInsuranceDimensionMembersLoadInsuranceDimensionMembers
        Synchronize insurance-specific dimension members from the insurance table to update contract and eligibility filtering options across the application.
        writes DimensionMember
        load insuranceload quote insuranceload eligibility insurance
      2. Load Time Dimensionssqlrevfind_process_loaddimensionmembers__load_time_dimensions.sql
        ✨ Builds time dimension members for days, months, and years based on account service dates to enable temporal reporting.
        writes DimensionMember · reads TransformAccount
      3. Load Provider Dimensionsqlrevfind_process_loaddimensionmembers__load_provider_dimension.sql
        ✨ Builds and updates the Provider and ProviderType dimensions, managing hierarchical relationships and identifying archived records.
        writes DimensionMember · reads DimensionMemberProvider
        ↳ feeds from Load AllowedStatus Dimensions, Load BilledToInsurance Dimensions, Load DenialCategory Dimensions, Load DiagnosisCode Dimension, Load Facility Dimensions, Load FacilityGroup Dimension, Load FacilityType Dimension, Load PlaceOfService Dimension, Load State Dimensions, Load Time Dimensions, LoadInsuranceDimensionMembers
      4. Load Facility Dimensionssqlrevfind_process_loaddimensionmembers__load_facility_dimensions.sql
        ✨ Builds and updates the Facility dimension by mapping source departments to specific facility groups and parent entities.
        writes DimensionMember · reads FacilitySourceDepartment_33143
      5. Load FacilityGroup Dimensionsqlrevfind_process_loaddimensionmembers__load_facilitygroup_dimension.sql
        ✨ Builds the FacilityGroup dimension by extracting unique parent entities from the existing Facility dimension members.
        writes DimensionMember · reads DimensionMember
        ↳ feeds from Load AllowedStatus Dimensions, Load BilledToInsurance Dimensions, Load DenialCategory Dimensions, Load DiagnosisCode Dimension, Load Facility Dimensions, Load FacilityType Dimension, Load PlaceOfService Dimension, Load Provider Dimension, Load State Dimensions, Load Time Dimensions, LoadInsuranceDimensionMembers
      6. Load FacilityType Dimensionsqlrevfind_process_loaddimensionmembers__load_facilitytype_dimension.sql
        ✨ Loads facility type dimension members from facility records to enable standardized categorization across the revenue cycle pipeline.
        writes DimensionMember · reads Facility
      7. Load SourceInsurance Dimensionssqlrevfind_process_loaddimensionmembers__load_sourceinsurance_dimensions.sql
        ✨ Builds and updates the SourceInsurance dimension using mapped insurance data for active accounts from the source system.
      8. Load PlaceOfService Dimensionsqlrevfind_process_loaddimensionmembers__load_placeofservice_dimension.sql
        ✨ Loads place of service dimension members from transformed charge data to categorize where healthcare services were provided.
        writes DimensionMember · reads TransformCharge
      9. Load DiagnosisCode Dimensionsqlrevfind_process_loaddimensionmembers__load_diagnosiscode_dimension.sql
        ✨ Loads unique diagnosis codes from charge records into the dimension member table to support standardized clinical reporting.
        writes DimensionMember · reads TransformCharge
      10. Load State Dimensionssqlrevfind_process_loaddimensionmembers__load_state_dimensions.sql
        ✨ Updates state dimensions using facility location data to allow for geographic segmentation of healthcare services and revenue.
        writes DimensionMember · reads Facility
      11. Load BilledToInsurance Dimensionssqlrevfind_process_loaddimensionmembers__load_billedtoinsurance_dimensions.sql
        ✨ Builds and updates the BilledToInsurance dimension using unique insurance identifiers and names from the source insurance map.
        writes DimensionMember · reads SourceInsuranceMap
      12. Load DenialCategory Dimensionssqlrevfind_process_loaddimensionmembers__load_denialcategory_dimensions.sql
        ✨ Loads denial category dimensions from adjustment code rollup data to categorize claim denials.
        writes DimensionMember · reads AdjustmentCodeRollup
      13. Load AllowedStatus Dimensionssqlrevfind_process_loaddimensionmembers__load_allowedstatus_dimensions.sql
        ✨ Builds allowed status dimensions to categorize how actual payments compare to expected insurance contract rates.
        writes DimensionMember
    7. ▶Job-[id]sub-job · 1↗
      1. Score Medicare SenarioBatchProcessAccounts
        writes AccountEstimate · reads QuoteBatchVisitBatch
        scenario insurance=Medicareincrementalupdate dimensions
    8. ▶RevFind-Process-ScoreAccountssub-job · 1↗
      1. BatchProcessAccountDataBatchProcessAccountData
        Calculates patient account estimates across multiple facilities and insurance types to update pricing after contract or configuration changes.
        writes AccountEstimate · reads QuoteBatchVisitBatch
        incremental
  9. ▶Revfind-Process-ContractModelingsub-job · 1↗
    1. ProcessScenarioModelProcessScenarioModel
      Calculates account estimates for queued scenario models to perform what-if analysis for contract modeling and pricing.