primus.command_worker.executors package

Concrete, reusable command executors.

class primus.command_worker.executors.PrimusCliExecutor(invoke_cli: Callable[[], None] | None = None)

Bases: object

Run a typed CLI request and publish its progress through ExecutionContext.

The transport contract deliberately accepts an argv array rather than a shell command string. This keeps dispatch data unambiguous and prevents command parsing from becoming an execution boundary. task_id is optional and is exposed only as the established CLI environment binding for task-aware commands.

__init__(invoke_cli: Callable[[], None] | None = None) → None

execute(envelope: CommandEnvelope, context: ExecutionContext) → str | int | float | bool | None | Mapping[str, JSONValue] | tuple[JSONValue, ...]

Submodules

• primus.command_worker.executors.primus_cli module
  • PrimusCliExecutor
    • PrimusCliExecutor.__init__()
    • PrimusCliExecutor.execute()
  • create_executor()