batchexec#

class Cancellable(*args, **kwargs)#

Bases: Protocol

cancel() → bool#

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#

nodes_required(batch: TestBatch) → int#: 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.

class HPCConnectSeriesRunner(backend: Backend)#

Bases: HPCConnectRunner

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

submit(batch: TestBatch, job: canary.Job) → Future#

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