attpcdaq.daq.tasks.organize_files_task¶

attpcdaq.daq.tasks.organize_files_task = <@task: attpcdaq.daq.tasks.organize_files_task of attpcdaq:0x7f59340ea748>[source]¶

Connects to the DAQ worker nodes to organize files at the end of a run.

This is done via SSH using the method organize_files() of the WorkerInterface object.

Parameters:	datarouter_pk (int) – Integer primary key of the data source experiment_pk (int) – The primary key of the current experiment run_pk (int) – The primary key of the most recent run