httk.workflow.runtime

Attempt identity and supervised commands.

The attempt context and run_command() are protocol-level facilities every native runner uses; the environment-binding helper below is what the authoring SDK and the Bash bridge both recover an attempt through.

Classes

AttemptContext	The immutable identity and restart evidence for one running attempt.
CommandResult	Result of an argv-only supervised child process.

Functions

run_command(→ CommandResult)

Run an argv array and terminate its process group on timeout.

Module Contents

class httk.workflow.runtime.AttemptContext

The immutable identity and restart evidence for one running attempt.

workspace_id: str

job_id: str

job_key: str

placement: str

step: str

activation_id: str

attempt_id: str

activation_ordinal: int | None

attempt_ordinal: int | None

total_attempts: int | None

is_restart: bool

is_unclean_restart: bool

attempt_reason: str | None

previous_attempt_id: str | None

activation_reason: str | None

workdir_mode: str | None

workdir_reused: bool

unsafe_persistent_takeover: bool

data_generation: int | None

durable: bool

settings: collections.abc.Mapping[str, object]

resources: collections.abc.Mapping[str, object]

join: object

raw: collections.abc.Mapping[str, Any]

classmethod read(path: str | os.PathLike[str]) → Self

Read and validate a manager-written attempt context.

class httk.workflow.runtime.CommandResult

Result of an argv-only supervised child process.

argv: tuple[str, Ellipsis]

returncode: int

stdout: bytes

stderr: bytes

timed_out: bool

httk.workflow.runtime.run_command(argv: collections.abc.Sequence[str], *, timeout: float | None = None, cwd: str | os.PathLike[str] | None = None, environment: collections.abc.Mapping[str, str] | None = None, termination_grace: float = 10.0) → CommandResult

Run an argv array and terminate its process group on timeout.