`ovo.core.scheduler.healthomics_scheduler`¶

Module Contents¶

Classes¶

HealthOmicsScheduler

API¶

class ovo.core.scheduler.healthomics_scheduler.HealthOmicsScheduler(name: str, workdir: str, reference_files_dir: str, aws: ovo.core.aws.AWSSessionManager, allow_submit: bool = True, submission_args: dict = None)¶

Bases: ovo.core.scheduler.base_scheduler.Scheduler

submit(pipeline_name: str, params: dict = None, submission_args: dict = None) → str¶

Submits a workflow asynchronously and returns the PID.

Parameters:

pipeline_name – Workflow name and revision (ovo.rfdiffusion-end-to-end or github url with @version)
params – Dictionary of parameters to pass to the workflow.
submission_args – Submission arguments for the scheduler, overrides values in self.submission_args

Returns:

Scheduler job ID

get_status_label(job_id: str) → str¶

Get human-readable job status label. Should NOT be used to determine job status.

Can return “Cancelled”, “Completed”, “Deleted”, “Failed”, “Pending”, “Running”, “Starting”, “Stopping”

get_result(job_id: str) → str | bool | None¶: Get job result: True if successful, False if failed, None if running.

_get_log_events(job_id: str, task_id: str = None, preview: bool = False) → list[mypy_boto3_logs.type_defs.OutputLogEventTypeDef]¶

get_log(job_id: str, task_id: str = None, preview: bool = False) → str | None¶

Get job execution log