openai4s/orchestration/slurm/backend.py

• SlurmBackend · class · L104-L417 — class SlurmBackend
• init · method · L109-L118 — def init( self, *, broker: SlurmBroker | None = None, cluster: ClusterConfig | None = None, log_dir: str | None = None, ) -> None
• _cluster_profile · method · L122-L133 — def _cluster_profile(self, profile: ResourceProfile) -> ClusterProfile
• _submit_spec · method · L135-L192 — def _submit_spec( self, allocation: Allocation, spec: WorkloadSpec, profile: ResourceProfile, ) -> SubmitSpec
• submit · method · L194-L248 — def submit( self, *, allocation: Allocation, spec: WorkloadSpec, profile: ResourceProfile, ) -> SubmitResult: # INV-8, first half: before submitting, ask whether this token is # already out there. A retry after an Unknown lands here and gets # Existing rather than a second job.
• run_task · method · L252-L289 — def run_task(self, allocation: Any, spec: Any) -> Any
• observe · method · L293-L334 — def observe(self, allocation: Allocation) -> Observation
• _observation_from · method · L336-L355 — def _observation_from(self, status: Any, allocation: Allocation) -> Observation
• cancel · method · L359-L362 — def cancel(self, allocation: Allocation, *, reason: Reason) -> None
• find_by_token · method · L364-L368 — def find_by_token(self, token: SubmissionToken) -> ExternalHandle | None
• _job_name_for_token · method · L370-L379 — def _job_name_for_token(self, token: SubmissionToken) -> str
• log_paths · method · L381-L400 — def log_paths(self, allocation_id: str) -> tuple[Path | None, Path | None]
• diagnostics · method · L402-L408 — def diagnostics(self) -> dict[str, Any]
• _handle · method · L412-L417 — def _handle(self, job_id: str) -> ExternalHandle
• _sh_quote · function · L420-L427 — def _sh_quote(value: str) -> str