swh.scheduler.simulator.common module#

class swh.scheduler.simulator.common.SimulationReport(total_visits: int = 0, visit_runtimes: Dict[Tuple[str, bool], List[float]] = <factory>, scheduler_metrics: List[Tuple[datetime.datetime, List[swh.scheduler.model.SchedulerMetrics]]] = <factory>, visit_metrics: List[Tuple[datetime.datetime, int]] = <factory>, latest_snapshots: Dict[Tuple[str, str], bytes] = <factory>)[source]#

Bases: object

DURATION_THRESHOLD = 3600#: Max duration for histograms

total_visits: int = 0#: Total count of finished visits

visit_runtimes: Dict[Tuple[str, bool], List[float]]#: Collected visit runtimes for each (status, eventful) tuple

scheduler_metrics: List[Tuple[datetime, List[SchedulerMetrics]]]#

Collected scheduler metrics

This is a list of couples (timestamp, [SchedulerMetrics,]): the list of scheduler metrics collected at given timestamp.

visit_metrics: List[Tuple[datetime, int]]#: Collected visit metrics over time

latest_snapshots: Dict[Tuple[str, str], bytes]#: Collected latest snapshots for origins

record_visit(origin: Tuple[str, str], duration: float, status: str, snapshot=typing.Optional[bytes]) → None[source]#

record_metrics(timestamp: datetime, scheduler_metrics: List[SchedulerMetrics])[source]#

property uneventful_visits#: Number of uneventful, full visits

runtime_histogram(status: str, eventful: bool) → str[source]#

metrics_plot() → str[source]#

metrics_csv(fobj: TextIO) → None[source]#: Export scheduling metrics in a csv file

format(with_plots=True)[source]#

class swh.scheduler.simulator.common.Task(visit_type: str, origin: str, backend_id: uuid.UUID = <factory>)[source]#

Bases: object

visit_type: str#

origin: str#

backend_id: UUID#

class swh.scheduler.simulator.common.TaskEvent(task: swh.scheduler.simulator.common.Task, status: swh.model.model.OriginVisitStatus, eventful: bool = False)[source]#

Bases: object

task: Task#

status: OriginVisitStatus#

eventful: bool = False#

class swh.scheduler.simulator.common.Queue(env, capacity=inf)[source]#

Bases: Store

Model a queue of objects to be passed between processes.

slots_remaining()[source]#

class swh.scheduler.simulator.common.Environment(start_time: datetime)[source]#

Bases: Environment

report: SimulationReport#

scheduler: SchedulerInterface#

property time#: Get the current simulated wall clock time