Package process

process.process_series

process_series.py

Helper functions for mercure’s processor module

async process.process_series.docker_runtime(task: Task, folder: Path, file_count_begin: int, task_processing: TaskProcessing) → bool

process.process_series.handle_processor_output(task: Task, task_processing: TaskProcessing, index: int, folder: Path) → Any

process.process_series.move_out_folder(task_id: str, source_folder: Path, destination_folder: Path, move_all=False) → None

process.process_series.move_results(task_id: str, folder: Path, lock: Optional[FileLock], processing_success: bool, needs_dispatching: bool) → None

async process.process_series.nomad_runtime(task: Task, folder: Path, file_count_begin: int, task_processing: TaskProcessing) → bool

process.process_series.push_input_images(task_id: str, input_folder: Path, output_folder: Path)

process.process_series.push_input_task(input_folder: Path, output_folder: Path)

process.process_series.trigger_notification(task: Task, event: mercure_events, details: str = '', send_always=False) → None

process.status

status.py

Helper functions for mercure’s processor module

process.status.is_ready_for_processing(folder) → bool

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