openai4s/orchestration/slurm/broker.py

• SlurmCommandError · class · L83-L113 — class SlurmCommandError(RuntimeError)
• init · method · L98-L113 — def init( self, message: str, *, command: tuple[str, ...] = (), returncode: int | None = None, stderr: str = "", timed_out: bool = False, unreachable: bool = False, ) -> None
• _assert_no_export_keyword · function · L116-L122 — def _assert_no_export_keyword(assembled: str) -> None
• _validate_env_value · function · L125-L148 — def _validate_env_value(key: str, value: str) -> None
• StepSpec · class · L152-L179 — class StepSpec
• post_init · method · L165-L179 — def post_init(self) -> None
• SubmitSpec · class · L183-L227 — class SubmitSpec
• post_init · method · L201-L227 — def post_init(self) -> None
• JobStatus · class · L231-L239 — class JobStatus
• _hhmmss · function · L242-L248 — def _hhmmss(seconds: int) -> str
• SlurmBroker · class · L251-L630 — class SlurmBroker
• init · method · L254-L266 — def init( self, *, timeout_s: float = DEFAULT_TIMEOUT_S, runner: Any = None, ) -> None
• available · method · L270-L275 — def available(self) -> bool
• _run · method · L277-L316 — def _run( self, command: list[str], *, stdin: str | None = None, timeout_s: float | None | object = _CONTROL_TIMEOUT, ) -> str
• _drain_capped · method · L319-L329 — def _drain_capped(stream: Any, *, limit: int, chunks: list[bytes]) -> None
• _run_step_capped · method · L331-L389 — def _run_step_capped(self, command: list[str]) -> str
• build_submit_argv · method · L393-L426 — def build_submit_argv(self, spec: SubmitSpec) -> list[str]
• submit · method · L428-L443 — def submit(self, spec: SubmitSpec) -> str
• build_step_argv · method · L445-L473 — def build_step_argv(self, job_id: str, spec: "StepSpec") -> list[str]
• run_step · method · L475-L482 — def run_step(self, job_id: str, spec: "StepSpec") -> str
• queue_status · method · L489-L517 — def queue_status(self, job_id: str) -> JobStatus | None
• _is_unknown_job_error · method · L520-L522 — def _is_unknown_job_error(exc: SlurmCommandError) -> bool
• accounting_status · method · L524-L534 — def accounting_status(self, job_id: str) -> JobStatus | None
• find_by_comment · method · L536-L591 — def find_by_comment(self, comment: str, *, job_name: str) -> str | None
• cancel · method · L593-L600 — def cancel(self, job_id: str) -> None
• _parse_row · method · L605-L630 — def _parse_row( stdout: str, fields: tuple[str, ...], *, separator: str = "|" ) -> JobStatus | None