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

sub-job

OrthoAlliance · RevFind-SBO-Source-LoadAthenaData

Adding 'Orthos' suffix to all source tables

called by RevFind-SBO-Daily-Processing-Accounts

sub-job OrthoAlliance/RevFind-SBO-Source-LoadAthenaData · db OrthoAlliance_ProdMirror · updated 2026-06-01

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-SBO-Source-LoadAthenaData

26 tasks · OrthoAlliance
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 SourceClaimMergeSql
    writes SourceClaimOrthos · reads CLAIM
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceClaimOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  2. Merge SourceClinicalEncounterMergeSql
    writes SourceClinicalEncounterOrthos · reads CLINICALENCOUNTER
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceClinicalEncounterOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  3. Merge SourceAppointmentMergeSql
    writes SourceAppointmentOrthos · reads APPOINTMENTCLAIM
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceAppointmentOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  4. Merge SourceTransactionMergeSql
    writes SourceTransactionOrthos · reads CLAIMTRANSACTION
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceTransactionOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  5. Merge SourceTransactionChargeMergeSqldisabled
    writes SourceTransactionCharge · reads SOURCETRANSACTION
    merge data source type=ThisDatabasetable name=SourceTransactionChargemerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  6. Merge SourceTransationPaymentMergeSqldisabled
    writes SourceTransactionPayment · reads SOURCETRANSACTION
    merge data source type=ThisDatabasetable name=SourceTransactionPaymentmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  7. Merge SourceTransactionAdjustmentMergeSqldisabled
    writes SourceTransactionAdjustment · reads SOURCETRANSACTION
    merge data source type=ThisDatabasetable name=SourceTransactionAdjustmentmerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  8. Merge SourceTransactionTransferMergeSqldisabled
    writes SourceTransactionTransfer · reads SOURCETRANSACTION
    merge data source type=ThisDatabasetable name=SourceTransactionTransfermerge mode=InsertUpdatebulk copy timeout seconds=300bulk copy use table lock
  9. Merge SourceERABatchMergeSql
    writes SourceERABatchOrthos · reads ERABATCH
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceERABatchOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  10. Merge SourceERARecordMergeSql
    writes SourceERARecordOrthos · reads ERARECORD
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceERARecordOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  11. Merge SourceERADetailMergeSql
    writes SourceERADetailOrthos · reads ERADETAILERARECORD
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceERADetailOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  12. Merge SourceERAKickMergeSql
    writes SourceERAKickOrthos · reads ERAKICK
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceERAKickOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  13. Merge SourceClaimNoteMergeSqldisabled
    writes SourceClaimNote · reads CLAIMNOTE
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceClaimNotemerge mode=InsertUpdatebulk copy timeout seconds=300
  14. Merge SourceDenialClaimNoteMergeSqldisabled
    writes SourceDenialClaimNote · reads DENIALCLAIMNOTE
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceDenialClaimNotemerge mode=InsertUpdatebulk copy timeout seconds=300
  15. Merge SourcePatientMergeSql
    writes SourcePatientOrthos · reads CLAIMPATIENT
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourcePatientOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  16. Merge SourcePayerMergeSql
    writes SourcePayerOrthos · reads INSURANCEPACKAGEPAYER
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourcePayerOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  17. Merge SourcePatientInsuranceMergeSql
    writes SourcePatientInsuranceOrthos · reads CLAIMPATIENTINSURANCE
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourcePatientInsuranceOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  18. Merge SourceProviderMergeSql
    writes SourceProviderOrthos · reads PROVIDER
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceProviderOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  19. Merge SourceDepartmentMergeSql
    writes SourceDepartmentOrthos · reads DEPARTMENT
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceDepartmentOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  20. Merge SourceFeeScheduleProcedureMergeSql
    writes SourceFeeScheduleProcedureOrthos · reads FEESCHEDULEPROCEDURE
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceFeeScheduleProcedureOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  21. Merge SourceProcedureCodeMergeSql
    writes SourceProcedureCodeOrthos · reads PROCEDURECODE
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceProcedureCodeOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  22. Merge SourceFeeScheduleMergeSql
    writes SourceFeeScheduleOrthos · reads FEESCHEDULE
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceFeeScheduleOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  23. Merge SourceProcedureCodeModifierMergeSql
    writes SourceProcedureCodeModifierOrthos · reads PROCEDURECODEMODIFIER
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceProcedureCodeModifierOrthosmerge mode=InsertUpdatebulk copy timeout seconds=300
  24. Merge SourceFeeScheduleDepartmentMergeSql
    writes SourceFeeScheduleDepartment · reads FEESCHEDULEDEPARTMENT
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceFeeScheduleDepartmentmerge mode=InsertUpdatebulk copy timeout seconds=300
  25. Merge FEESCHEDALLOWABLECATEGORYMergeSql
    writes SourceFeeSchedAllowableCategory · reads FEESCHEDALLOWABLECATEGORY
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceFeeSchedAllowableCategorymerge mode=InsertUpdatebulk copy timeout seconds=300
  26. Merge SourceAppointmentTypeMergeSql
    writes SourceAppointmentType · reads APPOINTMENTTYPE
    merge data source type=Snowflakeconnection string={AthenaConnectionString}table name=SourceAppointmentTypemerge mode=InsertUpdatebulk copy timeout seconds=300