primus.command_worker.runtime package

Container runtime entrypoints for the portable command worker.

class primus.command_worker.runtime.CommandWorkerRuntimeConfig(region: str, api_url: str, queue_url: str, queue_name: str, executor_factory: str, lease_duration: timedelta, heartbeat_interval: timedelta, visibility_timeout: timedelta, task_name: str, log_level: str)

Bases: object

Validated runtime bindings supplied by the deployment environment.

__init__(region: str, api_url: str, queue_url: str, queue_name: str, executor_factory: str, lease_duration: timedelta, heartbeat_interval: timedelta, visibility_timeout: timedelta, task_name: str, log_level: str) → None

api_url: str

executor_factory: str

classmethod from_environment(environment: Mapping[str, str] | None = None) → CommandWorkerRuntimeConfig

heartbeat_interval: timedelta

lease_duration: timedelta

log_level: str

queue_name: str

queue_url: str

region: str

task_name: str

visibility_timeout: timedelta

primus.command_worker.runtime.main() → None: Run the named command queue until the container is stopped by ECS.