Package process

process.process_series

process_series.py

Helper functions for mercure’s processor module

async process.process_series.docker_runtime(task: Task, folder: str, file_count_begin: int) bool[source]
process.process_series.move_out_folder(task_id: str, source_folder_str, destination_folder_str, move_all=False) None[source]
process.process_series.move_results(task_id: str, folder: str, lock: Optional[FileLock], processing_success: bool, needs_dispatching: bool) None[source]
process.process_series.nomad_runtime(task: Task, folder: str, file_count_begin: int) bool[source]
process.process_series.push_input_images(task_id: str, input_folder: Path, output_folder: Path)[source]
process.process_series.push_input_task(input_folder: Path, output_folder: Path)[source]
process.process_series.trigger_notification(task: Task, event) None[source]

process.status

status.py

Helper functions for mercure’s processor module

process.status.is_ready_for_processing(folder) bool[source]

Checks if a case in the processing folder is ready for the processor.