pcntoolkit.util.job_observer

Classes

`JobObserver`
`JobStatus`

Module Contents

class JobObserver(active_job_ids: Dict[str, str], job_type: str = 'local', log_dir: str = 'logs', task_id: str = '')

check_success_file(job_name: str) → bool: Check if a success file exists for the given job name.

get_job_statuses() → List[JobStatus]: Get status of all tracked jobs.

show_job_status_monitor(in_notebook, statuses)

wait_for_jobs(check_interval=1)

Wait for all submitted jobs to complete.

Args:: check_interval (int): Time in seconds between job status checks

active_job_ids

all_job_ids

job_id_to_name

job_type = 'local'

log_dir = 'logs'

task_id = ''

class JobStatus

job_id: str

name: str

nodes: str

state: str

success_file_exists: bool = False

time: str