`archivebox.api.v1_workers`

Module Contents

Classes

`TaskSchema`
`ActorSchema`
`OrchestratorSchema`

Functions

`get_orchestrators`	List all the task orchestrators (aka Orchestrators) that are currently running
`get_actors`	List all the task consumer workers (aka Actors) that are currently running

Data

router

API

archivebox.api.v1_workers.router[source]: ‘Router(…)’

class archivebox.api.v1_workers.TaskSchema[source]

Bases: ninja.Schema

TYPE: str[source]: None

id: uuid.UUID[source]: None

abid: str[source]: None

description: str[source]: None

status: str[source]: None

retry_at: datetime.datetime | None[source]: None

created_at: datetime.datetime[source]: None

modified_at: datetime.datetime[source]: None

created_by_id: int[source]: None

static resolve_description(obj) → str[source]

class archivebox.api.v1_workers.ActorSchema[source]

Bases: ninja.Schema

idle_count: int[source]: None

launch_kwargs: dict[str, Any][source]: None

mode: str[source]: None

model: str[source]: None

statemachine: str[source]: None

ACTIVE_STATE: str[source]: None

EVENT_NAME: str[source]: None

CLAIM_ORDER: list[str][source]: None

CLAIM_FROM_TOP_N: int[source]: None

CLAIM_ATOMIC: bool[source]: None

MAX_TICK_TIME: int[source]: None

MAX_CONCURRENT_ACTORS: int[source]: None

future: list[archivebox.api.v1_workers.TaskSchema][source]: None

pending: list[archivebox.api.v1_workers.TaskSchema][source]: None

stalled: list[archivebox.api.v1_workers.TaskSchema][source]: None

active: list[archivebox.api.v1_workers.TaskSchema][source]: None

past: list[archivebox.api.v1_workers.TaskSchema][source]: None

static resolve_model(obj) → str[source]

static resolve_statemachine(obj) → str[source]

static resolve_name(obj) → str[source]

static resolve_ACTIVE_STATE(obj) → str[source]

static resolve_FINAL_STATES(obj) → list[str][source]

static resolve_future(obj) → list[archivebox.api.v1_workers.TaskSchema][source]

static resolve_pending(obj) → list[archivebox.api.v1_workers.TaskSchema][source]

static resolve_stalled(obj) → list[archivebox.api.v1_workers.TaskSchema][source]

static resolve_active(obj) → list[archivebox.api.v1_workers.TaskSchema][source]

static resolve_past(obj) → list[archivebox.api.v1_workers.TaskSchema][source]

class archivebox.api.v1_workers.OrchestratorSchema[source]

Bases: ninja.Schema

exit_on_idle: bool[source]: None

mode: str[source]: None

actors: list[archivebox.api.v1_workers.ActorSchema][source]: None

static resolve_actors(obj) → list[archivebox.api.v1_workers.ActorSchema][source]

archivebox.api.v1_workers.get_orchestrators(request)[source]: List all the task orchestrators (aka Orchestrators) that are currently running

archivebox.api.v1_workers.get_actors(request)[source]: List all the task consumer workers (aka Actors) that are currently running

archivebox.api.v1_workers

Module Contents

Classes

Functions

Data

API

`archivebox.api.v1_workers`