buildgrid.server.scheduler.queue_timeout module

class buildgrid.server.scheduler.queue_timeout.QueueTimeoutThread(name: str, scheduler: Scheduler, instance_names: frozenset[str] | None, job_max_age: timedelta, handling_period: timedelta, max_handling_window: int)

Bases: object

instance_names: frozenset[str] | None

job_max_age: timedelta = datetime.timedelta(days=30)

handling_period: timedelta = datetime.timedelta(seconds=300)

max_handling_window: int = 10000

start() → None

stop() → None

begin(shutdown_requested: Event) → None

class buildgrid.server.scheduler.queue_timeout.QueueTimeoutConfig(name: str, job_max_age: dict[str, float], handling_period: dict[str, float] | None = None, max_handling_window: int | None = None, instance_names: frozenset[str] | None = None)

Bases: object

name: str

job_max_age: dict[str, float]

handling_period: dict[str, float] | None = None

max_handling_window: int | None = None

instance_names: frozenset[str] | None = None

generate_timeout_threads(scheduler: Scheduler) → Generator[QueueTimeoutThread, None, None]