httk.workflow.backends

Runner-backend contracts used by the workflow manager.

Classes

AttemptLaunch	Paths and context needed to construct an attempt command.
OutcomeCommit	A published outcome being committed by the authoritative manager.
RunnerBackend	Execution behavior selected by runner.backend in job.json.
PathRunnerBackend	The normal backend which directly executes runner.path.

Module Contents

class httk.workflow.backends.AttemptLaunch

Paths and context needed to construct an attempt command.

runner is the executable the manager resolved for this attempt. A payload runner is the file inside payload; a shared runner is the verified copy the manager staged below control, never the original.

job: httk.workflow.models.JobDefinition

marker: httk.workflow.models.Marker

payload: pathlib.Path

workdir: pathlib.Path

control: pathlib.Path

context_path: pathlib.Path

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

runner: pathlib.Path | None = None

property runner_command: pathlib.Path

Return the executable to run, defaulting to the payload runner.

class httk.workflow.backends.OutcomeCommit

A published outcome being committed by the authoritative manager.

job: httk.workflow.models.JobDefinition

marker: httk.workflow.models.Marker

payload: pathlib.Path

outcome_path: pathlib.Path

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

class httk.workflow.backends.RunnerBackend

Bases: Protocol

Execution behavior selected by runner.backend in job.json.

name: str

validate(job: httk.workflow.models.JobDefinition, payload: pathlib.Path) → None

Validate backend-specific immutable payload requirements.

abstractmethod command(launch: AttemptLaunch) → collections.abc.Sequence[str]

Return the command argument vector for one attempt.

commit_outcome(commit: OutcomeCommit) → None

Complete backend-specific idempotent work before the marker advances.

reconcile(workspace: httk.workflow.workspace.Workspace) → None

Repair backend-specific derived views; never alter authoritative state.

marker_changed(workspace: httk.workflow.workspace.Workspace, marker: httk.workflow.models.Marker) → None

Refresh derived views after an authoritative marker transition.

class httk.workflow.backends.PathRunnerBackend

The normal backend which directly executes runner.path.

name = 'path'

validate(job: httk.workflow.models.JobDefinition, payload: pathlib.Path) → None

command(launch: AttemptLaunch) → collections.abc.Sequence[str]

commit_outcome(commit: OutcomeCommit) → None

reconcile(workspace: httk.workflow.workspace.Workspace) → None

marker_changed(workspace: httk.workflow.workspace.Workspace, marker: httk.workflow.models.Marker) → None