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

sub-job

StrideCare · RevFind-Transform-Accounts

Athena Transforms

called by RevFind-Daily-Processing-Accounts-33143

sub-job StrideCare/RevFind-Transform-Accounts · db StrideCare_ProdMirror · updated 2025-11-21

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-Transform-Accounts

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