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

sub-job

SGP · RevFind-Source-MergeImportToSource

called by RevFind-Daily-Processing

sub-job SGP/RevFind-Source-MergeImportToSource · db SGP_ProdMirror · updated 2026-06-24

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-Source-MergeImportToSource

12 tasks · SGP
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. Merge ChargeMasterMergeSql
    writes SourceChargemaster · reads ImportChargemaster
    merge data source type=ThisDatabasetable name=SourceChargemastermerge mode=InsertUpdateSoftDeletebulk copy timeout seconds=300bulk copy use table lock
  2. TEMPORARY Fix for Dupe Encounterssqlrevfind_source_mergeimporttosource__temporary_fix_for_dupe_encounters.sql
    ✨ Removes duplicate encounter records from the import table to ensure data integrity before merging into source tables.
    writes cte · reads ImportEncounter
  3. Merge EncountersMergeSql
    writes SourceEncounter · reads ImportEncounter
    merge data source type=ThisDatabasetable name=SourceEncountermerge mode=InsertUpdateSoftDeletebulk copy timeout seconds=300bulk copy use table lock
  4. Merge PatientEncounterInsuranceMergeSqldisabled
    writes SourcePatientEncounterInsurance · reads ImportPatientEncounterInsurance
    merge data source type=ThisDatabasetable name=SourcePatientEncounterInsurancemerge mode=InsertUpdateHardDeletebulk copy timeout seconds=300bulk copy use table lock
  5. Merge PatientMergeSql
    writes SourcePatient · reads ImportPatient
    merge data source type=ThisDatabasetable name=SourcePatientmerge mode=InsertUpdateSoftDeletebulk copy timeout seconds=300bulk copy use table lock
  6. Merge ProviderMergeSql
    writes SourceProvider · reads ImportProvider
    merge data source type=ThisDatabasetable name=SourceProvidermerge mode=InsertUpdateSoftDeletebulk copy timeout seconds=300bulk copy use table lock
  7. Merge LocationMergeSql
    writes SourceLocation · reads ImportLocation
    merge data source type=ThisDatabasetable name=SourceLocationmerge mode=InsertUpdateSoftDeletebulk copy timeout seconds=300bulk copy use table lock
  8. Merge ChargeMergeSql
    writes SourceCharge · reads ImportCharge
    merge data source type=ThisDatabasetable name=SourceChargemerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  9. TEMPORARY Fix for dupe Txnssqlrevfind_source_mergeimporttosource__temporary_fix_for_dupe_txns.sql
    ✨ Removes duplicate transaction records from the import table based on matching IDs, amounts, and dates.
    writes CTE · reads ImportTransaction
  10. Merge TransactionMergeSql
    writes SourceTransaction · reads ImportTransaction
    merge data source type=ThisDatabasetable name=SourceTransactionmerge mode=InsertUpdateSoftDeletebulk copy timeout seconds=300bulk copy use table lock
  11. Merge InsuranceMergeSql
    writes SourceInsurance · reads ImportInsurance
    merge data source type=ThisDatabasetable name=SourceInsurancemerge mode=InsertUpdateSoftDeletebulk copy timeout seconds=300bulk copy use table lock
  12. Check Deleted Flag on Transactionssqlrevfind_source_mergeimporttosource__check_deleted_flag_on_transactions.sql
    ✨ Resets the deletion flag for transactions that have been updated or re-imported after being previously marked as deleted.
    · reads SourceTransaction
    ↳ feeds from Merge Transaction