pjkm.core.engine.task_runner

Task runner: executes a resolved task list, emitting events.

Exceptions

TaskRunError

Raised when a task fails during execution.

Classes

TaskRunner

Executes tasks in DAG-resolved order, grouped by phase.

Module Contents

exception pjkm.core.engine.task_runner.TaskRunError(task_id, message)

Bases: Exception

Raised when a task fails during execution.

Parameters:

• task_id (str)

• message (str)

task_id

class pjkm.core.engine.task_runner.TaskRunner(registry, on_event=None)

Executes tasks in DAG-resolved order, grouped by phase.

Parameters:

• registry (pjkm.core.tasks.registry.TaskRegistry)

• on_event (collections.abc.Callable[[pjkm.core.models.task.TaskEvent], None] | None)

run(ordered_definitions, ctx)

Execute tasks in the given order, updating context along the way.

Returns the list of all TaskResults (including skipped tasks). Raises TaskRunError if a task fails and success=False.

Parameters:

• ordered_definitions (list[pjkm.core.models.task.TaskDefinition])

• ctx (pjkm.core.engine.task_context.TaskContext)

Return type:

list[pjkm.core.models.task.TaskResult]