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

sub-job

USHP · RevFind-Source-ProcessNextGenData-DE

called by RevFind-Daily-Processing-Accounts

sub-job USHP/RevFind-Source-ProcessNextGenData-DE · db USHP_ProdMirror · updated 2026-03-10

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-ProcessNextGenData-DE

18 tasks · USHP
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. Download DEDownload
    Downloads files from remote FTP or SFTP servers to local directories with support for archiving and parallel transfers.
    server=USHP_ProdMirror-mdcssh-sftpremote directory=/USHP126051/local directory={SourceDataFolder}\USHP126051remote archive directory=/Archive/
  2. Clean AppointmentDE ExtractExecuteProcess
    command=powershell.exe
  3. Clean PatientInsuranceDE ExtractExecuteProcess
    command=powershell.exe
  4. Clean ChargeMasterDE ExtractExecuteProcess
    command=powershell.exe
  5. Process ExportAdjustmentDEProcessFile
    writes ImportAdjustmentDESourceAdjustmentDE
    archive directory={SourceDataArchive}\USHP126051base table name=AdjustmentDErow terminator=Linefeedcolumn separator=Pipe
  6. Load ExportAppointmentDEProcessFile
    writes ImportAppointmentDESourceAppointmentDE
    archive directory={SourceDataArchive}\USHP126051base table name=AppointmentDErow terminator=Linefeedcolumn separator=Pipe
  7. Load ExportChargeDEProcessFile
    writes ImportChargeDESourceChargeDE
    archive directory={SourceDataArchive}\USHP126051base table name=ChargeDErow terminator=Linefeedcolumn separator=Pipe
  8. Load ImportChargeMasterDEProcessFile
    writes ImportChargeMasterDESourceChargeMasterDE
    archive directory={SourceDataArchive}\USHP126051base table name=ChargeMasterDErow terminator=Linefeedcolumn separator=Pipe
  9. Load ExportEncounterDEProcessFile
    writes ImportEncounterDESourceEncounterDE
    archive directory={SourceDataArchive}\USHP126051base table name=EncounterDErow terminator=Linefeedcolumn separator=Pipe
  10. Load ImportEncounterInsuranceDE DataFileLoadFile
    writes ImportEncounterInsuranceDE
    data file spec=ImportEncounterInsuranceDEimport mode=Replacearchive file path={SourceDataArchive}\USHP126051
  11. Load SourceEncounterInsuranceDEsqlrevfind_source_processnextgendata_de__load_sourceencounterinsurancede.sql
    ✨ Loads Delaware encounter insurance data from import tables into the source staging area for further processing.
    writes sourceencounterinsuranceDE · reads ImportEncounterInsuranceDE
    ↳ feeds from Load ImportEncounterInsuranceDE DataFile
  12. Load ExportEventDEProcessFile
    writes ImportEventDESourceEventDE
    archive directory={SourceDataArchive}\USHP126051base table name=EventDErow terminator=Linefeedcolumn separator=Pipe
  13. Load ExportLocationDEProcessFile
    writes ImportLocationDESourceLocationDE
    archive directory={SourceDataArchive}\USHP126051base table name=LocationDErow terminator=Linefeedcolumn separator=Pipe
  14. Load ExportPatientDEProcessFile
    writes ImportPatientDESourcePatientDE
    archive directory={SourceDataArchive}\USHP126051base table name=PatientDErow terminator=Linefeedcolumn separator=Pipe
  15. Load ExportPatientInsuranceDEProcessFile
    writes ImportPatientInsuranceDESourcePatientInsuranceDE
    archive directory={SourceDataArchive}\USHP126051base table name=PatientInsuranceDErow terminator=Linefeedcolumn separator=Pipe
  16. Load ExportPayerDEProcessFile
    writes ImportPayerDESourcePayerDE
    archive directory={SourceDataArchive}\USHP126051base table name=PayerDErow terminator=Linefeedcolumn separator=Pipe
  17. Load ExportProviderDEProcessFile
    writes ImportProviderDESourceProviderDE
    archive directory={SourceDataArchive}\USHP126051base table name=ProviderDErow terminator=Linefeedcolumn separator=Pipe
  18. Process ExportTransactionDetailDE DataFileProcessFile
    writes ImportTransactionDetailDESourceTransactionDetailDE
    archive directory={SourceDataArchive}\USHP126051base table name=TransactionDetailDErow terminator=Linefeedcolumn separator=Pipe