Batch / file feed · RevFind pipeline
CCP · Daily-Accounts-Processing
Overall daily batch accounts processing job
trigger
How it's scheduled
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 task | Cadence | Server | State | Coordination |
|---|---|---|---|---|
\MDC\Daily - Processing - CCP | daily at 04:30 | prod-db-3 | enabled | standalone |
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.
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).
Payers in SQLMedicare
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).
Daily-Accounts-Processing
▶Process-Experity-Datasub-job · 18↗
- Process ExportLogBookTableProcessFilewrites
ImportLogBookSourceLogBookarchive directory={SourceDataArchive}base table name=LogBookrow terminator=Newlinecolumn separator=Pipe - Process ExportLogDetailTableProcessFilewrites
ImportLogDetailSourceLogDetailarchive directory={SourceDataArchive}base table name=LogDetailrow terminator=Newlinecolumn separator=Pipe - Process ExportChargeHeaderTableProcessFilewrites
ImportChargeHeaderSourceChargeHeaderarchive directory={SourceDataArchive}base table name=ChargeHeaderrow terminator=Newlinecolumn separator=Pipe - Process ExportChargeDetailTableProcessFilewrites
ImportChargeDetailSourceChargeDetailarchive directory={SourceDataArchive}base table name=ChargeDetailrow terminator=Newlinecolumn separator=Pipe - Process ExportARHeaderTableProcessFilewrites
ImportARHeaderSourceARHeaderarchive directory={SourceDataArchive}base table name=ARHeaderrow terminator=Newlinecolumn separator=Pipe - Process ExportARDetailTableProcessFilewrites
ImportARDetailSourceARDetailarchive directory={SourceDataArchive}base table name=ARDetailrow terminator=Newlinecolumn separator=Pipe - Process ExportERAAdjustmentTableProcessFilewrites
ImportERAAdjustmentSourceERAAdjustmentarchive directory={SourceDataArchive}base table name=ERAAdjustmentrow terminator=Newlinecolumn separator=Pipe - Process ExportERAClaimTableProcessFilewrites
ImportERAClaimSourceERAClaimarchive directory={SourceDataArchive}base table name=ERAClaimrow terminator=Newlinecolumn separator=Pipe - Process ExportERAServiceTableProcessFilewrites
ImportERAServiceSourceERAServicearchive directory={SourceDataArchive}base table name=ERAServicerow terminator=Newlinecolumn separator=Pipe - Process ExportPatientTableProcessFilewrites
ImportPatientSourcePatientarchive directory={SourceDataArchive}base table name=Patientrow terminator=Newlinecolumn separator=Pipe - Process ExportPatBillingTableProcessFilewrites
ImportPatBillingSourcePatBillingarchive directory={SourceDataArchive}base table name=PatBillingrow terminator=Newlinecolumn separator=Pipe - Process ExportInsuranceTableProcessFilewrites
ImportInsuranceSourceInsurancearchive directory={SourceDataArchive}base table name=Insurancerow terminator=Newlinecolumn separator=Pipe - Process ExportPayerTableProcessFilewrites
ImportPayerSourcePayerfile path={SourceDataFolder}\ExportPayerTable.txtarchive directory={SourceDataArchive}base table name=Payerrow terminator=Newlinecolumn separator=Pipe - Process ExportProviderTableProcessFilewrites
ImportProviderSourceProviderarchive directory={SourceDataArchive}base table name=Providerrow terminator=Newlinecolumn separator=Pipe - Process ExportLocationTableProcessFilewrites
ImportLocationSourceLocationarchive directory={SourceDataArchive}base table name=Locationrow terminator=Newlinecolumn separator=Pipe - Process ExportFeeScheduleTableProcessFilewrites
ImportFeeScheduleSourceFeeSchedulearchive directory={SourceDataArchive}base table name=FeeSchedulerow terminator=Newlinecolumn separator=Pipe - Process ExportUtilGroupTableProcessFilewrites
ImportUtilGroupSourceUtilGrouparchive directory={SourceDataArchive}base table name=UtilGrouprow terminator=Newlinecolumn separator=Pipe
▶Load-Entitiessub-job · 2↗Load Facility, Provider
- Load FacilityLoadEntitieswrites
Facility· readsSourceLocationentity type=Facilitycustom query - Load Providersql
load_entities__load_provider.sql✨ Builds and updates the provider master list by merging source provider details, taxonomy codes, and NPI information.writesProvider· readsProviderTaxonomySourceLogDetailSourceProvider
▶Load-InsuranceMapsub-job · 2↗
- Load InsuranceMap rawProcessFiledisabledwrites
ImportInsuranceMapSourceInsuranceMapfile path=D:\ClientData\CCP\InsuranceMap.csvbase table name=InsuranceMaprow terminator=Newlinecolumn separator=CommaDISABLED - Load InsuranceMapLoadEntitieswrites
InsuranceMap· readsInsuranceMapSourceARHeaderSourceInsuranceSourcePatBillingentity type=InsuranceMapauto querykey prefix=IM
▶Load-Charge-Dimensionsub-job · 9↗
- Load TempChargeSchedulessql
load_charge_dimension__load_tempchargeschedules.sql✨ Builds temporary charge schedules by calculating effective date ranges for professional and facility fee schedules from the master charge list.writesTempChargeSchedules - Load FeeScheduleRecordsql
load_charge_dimension__load_feeschedulerecord.sql✨ Loads fee schedule records with charge codes, modifiers, and pricing for specific professional and facility practice schedules.writesFeeScheduleRecord· readsSourceChargeMasterTempChargeSchedules↳ feeds from Load TempChargeSchedules - Load ScheduleMapsql
load_charge_dimension__load_schedulemap.sql✨ Maps fee schedules to specific facilities and insurance categories for professional and ambulatory surgery center services.writesScheduleMap· readsFacilityTempChargeSchedules↳ feeds from Load TempChargeSchedules - Load ContractMapsql
load_charge_dimension__load_contractmap.sqldisabled✨ Defines contract mappings for charge-based and self-pay accounts across various facility types and practice settings.writesContractMap· readsFacility - Load ScheduleLoadEntitieswrites
Schedule· readsTempChargeSchedules↳ feeds from Load TempChargeSchedulesentity type=Schedulecustom query - Load ChargeTypesql
load_charge_dimension__load_chargetype.sql✨ Categorizes charge types by mapping procedure codes, modifiers, and service types from the fee schedule and charge data.writesChargeType· readsSourceFeeScheduleTransformCharge - Load ChargeType Dimensionsql
load_charge_dimension__load_chargetype_dimension.sql✨ Updates the charge type dimension with standardized member names and display labels for reporting and analysis.writesDimensionMember· readsChargeType↳ feeds from Load ChargeType - Load ProcedureCode Dimensionsql
load_charge_dimension__load_procedurecode_dimension.sql✨ Updates the procedure code dimension by extracting codes and assigning parent categories for hierarchical reporting.writesDimensionMember· readsChargeType↳ feeds from Load ChargeType - Load ProcedureCategory and Subcategory DMsql
load_charge_dimension__load_procedurecategory_and_subcategory_dm.sql✨ Builds procedure category and subcategory dimensions by mapping charge codes to standardized hierarchies for clinical reporting.writesDimensionMember· readsSourceChargeMap
▶Load-Account-Transform-Tablessub-job · 9↗Source-->Transform
- Load AccountDeltasql
load_account_transform_tables__load_accountdelta.sql✨ Builds a list of account identifiers from the import log to track records requiring transformation in the current pipeline run.writesAccountDelta· readsAccountDelta - Load TransformPatientsql
load_account_transform_tables__load_transformpatient.sql✨ Updates or inserts patient demographic information, including names, contact details, and addresses, from source data into the transformed patient table.writesTransformPatient· readsSourcePatient - Load TransformInvoiceChainsql
load_account_transform_tables__load_transforminvoicechain.sql✨ Builds a historical chain of invoice relationships for specific accounts, identifying current, cloned, and rebilled charge headers.writesTransformInvoiceChain· readsAccountDeltaSourceChargeHeader↳ feeds from Load AccountDelta - Load TransformAccountsql
load_account_transform_tables__load_transformaccount.sql✨ Consolidates account-level details, including facility, patient, and primary insurance information, for records identified in the current processing delta.writesTransformAccount· readsAccountDeltaSourceInsuranceSourceLocationSourceLogBookSourceLogDetailSourcePatBillingTransformInvoiceChain↳ feeds from Load AccountDelta, Load TransformInvoiceChain - Load TransformChargesql
load_account_transform_tables__load_transformcharge.sql✨ Loads detailed service charge information, including procedure codes, modifiers, and payment balances, for accounts requiring updates.writesTransformCharge· readsAccountDeltaSourceChargeDetailSourceChargeHeaderSourceInsuranceSourcePatBillingTransformInvoiceChain↳ feeds from Load AccountDelta, Load TransformInvoiceChain - Load TransformTransactionsql
load_account_transform_tables__load_transformtransaction.sql✨ Records financial transactions, such as payments and adjustments, while establishing chronological posting orders for each account's billing history.writesTransformTransaction· readsAccountDeltaSourceARDetailSourceARHeaderSourceInsuranceSourcePatBilling↳ feeds from Load AccountDelta - Load TransformRemitAdjustmentsql
load_account_transform_tables__load_transformremitadjustment.sql✨ Loads insurance remittance adjustments and denial codes from electronic advice, linking them to specific charges and invoice chains.writesTransformRemitAdjustment· readsAccountDeltaAdjustmentCodeRollupSourceARHeaderSourceERAAdjustmentSourceInsuranceSourcePatBillingTransformAccountTransformInvoiceChain↳ feeds from Load AccountDelta, Load TransformAccount, Load TransformInvoiceChain - Load TransformRemitAdjustmentAggsql
load_account_transform_tables__load_transformremitadjustmentagg.sql✨ Aggregates insurance denial data by category and amount to summarize initial and final remittance adjustments for each account.writesTransformRemitAdjustmentAgg· readsAccountDeltaTransformRemitAdjustment↳ feeds from Load AccountDelta, Load TransformRemitAdjustment - Load TransformChargeTransactionMeasuresql
load_account_transform_tables__load_transformchargetransactionmeasure.sql✨ Builds financial measures for charges, including payments, adjustments, and denials, while mapping coordination of benefits and denial categories.writesTransformChargeTransactionMeasure· readsAccountDeltaTransformAccountTransformChargeTransformInvoiceChainTransformRemitAdjustmentAggTransformTransaction↳ feeds from Load AccountDelta, Load TransformAccount, Load TransformCharge, Load TransformInvoiceChain, Load TransformRemitAdjustmentAgg, Load TransformTransaction
▶Load-Patient-Entitysub-job · 1↗
- Execute LoadPatientsLoadPatientsUpsert patient records into the patient dimension.· reads
PatientTransformPatientcustom patient query
▶Load-Dimension-Memberssub-job · 22↗
- Load Insurance Dimensionsql
load_dimension_members__load_insurance_dimension.sql✨ Loads the insurance dimension with unique insurance keys and a placeholder for unmapped records to support payer-level analysis.writesDimensionMember· readsInsurance - Load SourceInsurance Dimensionsql
load_dimension_members__load_sourceinsurance_dimension.sql✨ Builds the source insurance dimension by linking insurance maps to source system details and financial classifications.writesDimensionMember· readsInsuranceMapSourceInsurance - Load FinancialClass Dimensionsql
load_dimension_members__load_financialclass_dimension.sql✨ Loads financial class dimensions by grouping payers into standardized categories based on source utility group definitions.writesDimensionMember· readsDimensionMemberSourceUtilGroup↳ feeds from Load ClaimStatus Dimension, Load DenialCategory Dimension, Load DiagnosisCode Dimension, Load Facility Dimensions, Load FacilityType Dimensions, Load Insurance Dimension, Load PatientAge Dimension, Load PatientSex Dimension, Load PlaceOfService Dimensions, Load Practice Dimensions, Load Provider Dimension, Load ProviderType Dimension, Load QuoteInsurance Dimension, Load SourceInsurance Dimension, Load State Dimension, Load Time Dimensions - Load EligibilityInsurance Dimensionsql
load_dimension_members__load_eligibilityinsurance_dimension.sqldisabled✨ Loads insurance members that support electronic eligibility and benefits verification via API integration.writesDimensionMember· readsDimensionMemberInsurance - Load QuoteInsurance Dimensionsql
load_dimension_members__load_quoteinsurance_dimension.sql✨ Builds a dimension of insurance providers associated with active contracts to facilitate accurate patient cost estimates.writesDimensionMember· readsContractMapInsurance - Load Time Dimensionssql
load_dimension_members__load_time_dimensions.sql✨ Builds time dimensions including day, month, and year levels based on the range of service dates in the account data.writesDimensionMember· readsTransformAccount - Load VisitStatus Dimensionsql
load_dimension_members__load_visitstatus_dimension.sqldisabled✨ Loads unique appointment statuses into the visit status dimension to categorize and track the current state of patient visits.writesDimensionMember· readsTransformVisit - Load DenialCategory Dimensionsql
load_dimension_members__load_denialcategory_dimension.sql✨ Updates the denial category dimension with standardized codes and descriptions to classify and analyze insurance claim rejections.writesDimensionMember· readsAdjustmentCodeRollup - Load Provider Dimensionsql
load_dimension_members__load_provider_dimension.sql✨ Loads healthcare provider details and their associated types into the provider dimension for clinical and financial reporting.writesDimensionMember· readsProvider - Load ProviderType Dimensionsql
load_dimension_members__load_providertype_dimension.sql✨ Builds the provider type dimension by extracting unique provider categories to enable high-level grouping of medical staff.writesDimensionMember· readsDimensionMember↳ feeds from Load ClaimStatus Dimension, Load DenialCategory Dimension, Load DiagnosisCode Dimension, Load Facility Dimensions, Load FacilityType Dimensions, Load FinancialClass Dimension, Load Insurance Dimension, Load PatientAge Dimension, Load PatientSex Dimension, Load PlaceOfService Dimensions, Load Practice Dimensions, Load Provider Dimension, Load QuoteInsurance Dimension, Load SourceInsurance Dimension, Load State Dimension, Load Time Dimensions - Load Facility Dimensionssql
load_dimension_members__load_facility_dimensions.sql✨ Updates the facility dimension with location names and group associations to organize data by specific service sites.writesDimensionMember· readsFacility - Load FacilityType Dimensionssql
load_dimension_members__load_facilitytype_dimensions.sql✨ Loads unique facility types into the dimension table to allow for the categorization of different healthcare service locations.writesDimensionMember· readsFacility - Load Practice Dimensionssql
load_dimension_members__load_practice_dimensions.sql✨ Populates the practice dimension with unique medical practice names to facilitate reporting across different business entities.writesDimensionMember· readsSourceLocation - Load PlaceOfService Dimensionssql
load_dimension_members__load_placeofservice_dimensions.sql✨ Updates the place of service dimension with standardized codes and descriptions for locations where healthcare services were provided.writesDimensionMember· readsPOSCodesTransformCharge - Load VisitType Dimensionssql
load_dimension_members__load_visittype_dimensions.sqldisabled✨ Loads visit type dimensions from HL7 visit data to standardize appointment categories for reporting.writesDimensionMember· readsHL7Visit - Load AccountStatus Dimensionsql
load_dimension_members__load_accountstatus_dimension.sqldisabled✨ Updates account status dimensions using encounter status information to track the lifecycle of patient accounts.writesDimensionMember· readsSourceEncounter - Load AllowedStatus Dimensionsql
load_dimension_members__load_allowedstatus_dimension.sqldisabled✨ Builds allowed status dimensions to categorize how actual payments compare to expected insurance contract rates.writesDimensionMember - Load ClaimStatus Dimensionsql
load_dimension_members__load_claimstatus_dimension.sql✨ Loads claim status dimensions to define the various stages of the insurance billing and reimbursement process.writesDimensionMember - Load DiagnosisCode Dimensionsql
load_dimension_members__load_diagnosiscode_dimension.sql✨ Builds diagnosis code dimensions by extracting codes from account charges and mapping them to standardized medical categories.writesDimensionMember· readsAccountChargeDimensionMember↳ feeds from Load ClaimStatus Dimension, Load DenialCategory Dimension, Load Facility Dimensions, Load FacilityType Dimensions, Load FinancialClass Dimension, Load Insurance Dimension, Load PatientAge Dimension, Load PatientSex Dimension, Load PlaceOfService Dimensions, Load Practice Dimensions, Load Provider Dimension, Load ProviderType Dimension, Load QuoteInsurance Dimension, Load SourceInsurance Dimension, Load State Dimension, Load Time Dimensions - Load PatientAge Dimensionsql
load_dimension_members__load_patientage_dimension.sql✨ Loads patient age dimensions by calculating current ages from birth dates to support demographic analysis.writesDimensionMember· readsPatient - Load PatientSex Dimensionsql
load_dimension_members__load_patientsex_dimension.sql✨ Loads patient sex dimensions from demographic records to enable gender-based reporting and filtering within the pipeline.writesDimensionMember· readsPatient - Load State Dimensionsql
load_dimension_members__load_state_dimension.sql✨ Updates state dimensions using facility location data to allow for geographic segmentation of healthcare services and revenue.writesDimensionMember· readsFacility
▶Load-Account-Datasub-job · 14↗Load Account-Level Tables
- ReprocessChangedConfigurationsReprocessChangedConfigurationsIdentify and queue visits or accounts affected by configuration changes to ensure historical data reflects updated pricing or insurance rules.reprocess accounts
- AccountsToReprocess -> AccountDeltasql
load_account_data__accountstoreprocess_accountdelta.sql✨ Identifies and adds unique account IDs requiring reprocessing to the delta table for incremental updates.writesAccountDelta· readsAccountDeltaAccountsToReprocess - Load ChargeMeasuressql
load_account_data__load_chargemeasures.sql✨ Updates charge-level financial metrics, including payments, adjustments, and denial categories, for accounts identified in the delta table.writesChargeMeasures· readsAccountDeltaTransformAccountTransformChargeTransformChargeTransactionMeasure↳ feeds from AccountsToReprocess -> AccountDelta - Load AccountChargesql
load_account_data__load_accountcharge.sqldisabled✨ Rebuilds the charge measures table by aggregating financial data and denial categories for current charges within the delta set.writesAccountChargeChargeMeasures· readsAccountDeltaChargeMeasuresChargeTypePatientProviderTransformAccountTransformCharge - Load Accountsql
load_account_data__load_account.sqldisabled✨ Updates the account table with aggregated financial totals, insurance mapping, and primary denial categories for accounts in the delta.writesAccount· readsAccountChargeAccountDeltaInsuranceMapPatientTransformAccountTransformChargeTransactionMeasure - Load AccountRemitsql
load_account_data__load_accountremit.sqldisabled✨ Loads detailed remittance and transaction history, including payment descriptions and payer information, for accounts requiring updates.writesAccountRemit· readsAccountDeltaInsuranceMapTransformAccountTransformChargeTransformTransaction - Clean Estimatessql
load_account_data__clean_estimates.sqldisabled✨ Removes outdated non-scenario insurance estimates and associated charge calculations for encounters identified in the delta table.writesAccountEstimateAccountEstimateCalculationAccountEstimateCharge· readsAccountEstimateEncounterDelta - LoadAccountDataLoadAccountDataImports historical billing data from external systems into core account tables while preserving manual user modifications and application fields.· reads
AccountChargeAccountDeltaChargeMeasuresChargeTypeInsuranceMapPatientProviderSourcePatBilling↳ feeds from AccountsToReprocess -> AccountDelta, Load ChargeMeasurescustom account charge querycustom account querycustom account remit querycustom account insurance query ▶Score-Accountssub-job · 1↗
- BatchProcessAccountDataBatchProcessAccountDataCalculates patient account estimates across multiple facilities and insurance types to update pricing after contract or configuration changes.writes
AccountEstimate· readsQuoteBatchVisitBatchincremental
▶Load-Custom-Propertiessub-job · 4↗
- Update Has DenialUpdateCustomPropertyFromQuery· reads
Accountaccountdeltaentity=Accountcustom property key=HasDenialcustom query - Update Allowed StatusUpdateCustomPropertyFromQuery· reads
AccountAccountEstimateaccountdeltaentity=Accountcustom property key=AllowedStatuscustom query ▶Load-Custom-Property-Memberssub-job · 1↗
- Experity Insurancesql
load_custom_property_members__experity_insurance.sql✨ Updates custom insurance property members using active mapping data to maintain consistent display names and ordering.writesCustomPropertyMember· readsInsuranceMap
- Update ExperityInsuranceUpdateCustomPropertyFromQuery· reads
InsuranceMapTransformAccountaccountdeltaentity=Accountcustom property key=ExperityInsurancecustom query
- Load AccountDetailsql
load_account_data__load_accountdetail.sqldisabled✨ Populates a comprehensive account detail table merging patient demographics, provider information, and financial performance metrics for delta accounts.writesAccountDetail· readsAccountAccountChargeAccountDeltaAccountEstimateDimensionMemberPatientSourceEncounterInsuranceSourcePayer - Load AccountChargeDetailsql
load_account_data__load_accountchargedetail.sqldisabled✨ Loads granular charge-level details, including procedure codes, modifiers, and specific financial balances, for accounts in the delta set.writesAccountChargeDetail· readsAccountAccountChargeAccountDeltaAccountEstimateCalculationAccountEstimateChargeDimensionMemberPatientSourceEncounterInsurance - WorkqueueAssignmentWorkqueueAssignmentAssigns accounts or visits to workqueue stacks by evaluating matching criteria and updating item lists based on search terms.
- Execute Update Dashboard TablesUpdateDashboardTablesRegenerates optimized aggregate tables for all dashboard reports and updates their definitions to reflect the latest source data.