batchexec#

class Cancellable(*args, **kwargs)#

Bases: Protocol

cancel() → bool#

class BatchResourceFailure(job_id: str, job_name: str, reason: str)#

Bases: object

job_id: str#

job_name: str#

reason: str#

format() → str#

class HPCConnectRunner(backend: Backend)#

Bases: object

execute(batch: TestBatch, queue: SimpleQueue) → int | None#

rc_environ(batch: TestBatch) → dict[str, str | None]#

scheduler_args() → list[str]#

handle_signals(targets: Sequence[Cancellable], batch: TestBatch)#

generate_resource_pool(batch: TestBatch) → None#

validate_batch(batch: TestBatch) → list[BatchResourceFailure]#

nodes_required(batch: TestBatch) → int#: Return number of scheduler nodes required to run jobs in batch.

class HPCConnectBatchRunner(backend: Backend)#

Bases: HPCConnectRunner

execute(batch: TestBatch, queue: SimpleQueue) → int | None#

submit(batch: TestBatch) → Future#

canary_invocation(batch: TestBatch) → str#: Write the canary invocation used to run this batch.