archivebox.workers.orchestrator

Module Contents

Classes

Orchestrator

API

class archivebox.workers.orchestrator.Orchestrator(actor_types: Dict[str, Type[archivebox.workers.actor.ActorType]] | None = None, mode: Literal[thread, process] | None = None, exit_on_idle: bool = True, max_concurrent_actors: int = max_concurrent_actors)[source]

Initialization

pid: int[source]

None

idle_count: int[source]

0

actor_types: Dict[str, Type[archivebox.workers.actor.ActorType]][source]

None

mode: Literal[thread, process][source]

‘process’

exit_on_idle: bool[source]

True

max_concurrent_actors: int[source]

20

__repr__() → str[source]
__str__() → str[source]
name() → str[source]
_fork_as_process()[source]
start() → int[source]
classmethod autodiscover_actor_types() → Dict[str, Type[archivebox.workers.actor.ActorType]][source]
classmethod get_orphaned_objects(all_queues) → list[source]
classmethod has_future_objects(all_queues) → bool[source]
on_startup()[source]
on_shutdown(err: BaseException | None = None)[source]
on_tick_started(all_queues)[source]
on_tick_finished(all_queues, all_existing_actors, all_spawned_actors)[source]
on_idle(all_queues)[source]
runloop()[source]