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

sub-job

SSR · Load-Schedule-Data-Files

called by Daily-Processing

sub-job SSR/Load-Schedule-Data-Files · db SouthSoundRadiology_ProdMirror · updated 2025-09-17

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

Load-Schedule-Data-Files

1 tasks · SSR
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. Load-Schedule-Data-Filesub-job · 9
    1. Load Schedule Data FileLoadFile
      writes ImportScheduleData
      data file spec=ImportScheduleDatafile path={FilePath}import mode=Replace
    2. Load SourcePatientAppointmentsqlload_schedule_data_file__load_sourcepatientappointment.sql
      Transforms and loads imported schedule data into the source appointment table, mapping patient demographics, insurance details, and procedure information.
      writes SourcePatientAppointment · reads ImportScheduleData
      ↳ feeds from Load Schedule Data File
    3. Load TempPatientDeltasqlload_schedule_data_file__load_temppatientdelta.sql
      Creates a temporary list of unique patient IDs from the imported schedule data to identify records requiring updates.
      writes TempPatientDelta
    4. Load Patients - Oldsqlload_schedule_data_file__load_patients_old.sqldisabled
      Updates the master patient table with demographic information derived from the earliest recorded appointment for each patient in the delta.
      writes PatientTempNextPatientAppointmentDemographics · reads TempNextPatientAppointmentDemographics
    5. Load TempNextPatientAppointmentDemographicssqlload_schedule_data_file__load_tempnextpatientappointmentdemographics.sql
      Extracts the most recent demographic information for patients in the delta into a temporary table based on their latest appointment.
      writes TempNextPatientAppointmentDemographics
    6. Load PatientsLoadPatients
      Upsert patient records into the patient dimension.
      · reads PatientTempNextPatientAppointmentDemographics
      ↳ feeds from Load TempNextPatientAppointmentDemographics
      auto patient query
    7. Load ImportScheduleDataArchivesqlload_schedule_data_file__load_importscheduledataarchive.sql
      Archives current schedule data into a historical storage table with a timestamp for record-keeping.
      writes ImportScheduleDataArchive · reads ImportScheduleData
      ↳ feeds from Load Schedule Data File
    8. Delete History from ImportScheduleDataArchivesqlload_schedule_data_file__delete_history_from_importscheduledataarchive.sql
      Deletes archived schedule data older than thirty days to maintain the size of the historical storage table.
      writes ImportScheduleDataArchive
    9. Archive FileExecuteProcess
      command=cmd.exe