diff --git a/docs/simulator.rst b/docs/simulator.rst --- a/docs/simulator.rst +++ b/docs/simulator.rst @@ -74,7 +74,7 @@ For now it is only a simple approximation designed to exercise simple cases: origin creation/discovery, a continuous stream of commits, and failure if they have too many commits to load at once. -For details, see :py:`swh.scheduler.simulator.origins`. +For details, see :py:mod:`swh.scheduler.simulator.origins`. To keep the simulation fast enough, each origin's state is kept in memory, so the simulator process will linearly increase in memory usage as it runs. diff --git a/swh/scheduler/simulator/origin_scheduler.py b/swh/scheduler/simulator/origin_scheduler.py --- a/swh/scheduler/simulator/origin_scheduler.py +++ b/swh/scheduler/simulator/origin_scheduler.py @@ -47,8 +47,8 @@ env: Environment, status_queue: Queue ) -> Generator[Event, TaskEvent, None]: """Scheduler journal client. Every once in a while, pulls - `OriginVisitStatus`es from the status_queue to update the scheduler - origin_visit_stats table.""" + :class:`OriginVisitStatuses ` + from the status_queue to update the scheduler origin_visit_stats table.""" BATCH_SIZE = 100 statuses: List[Dict[str, Any]] = [] diff --git a/swh/scheduler/task.py b/swh/scheduler/task.py --- a/swh/scheduler/task.py +++ b/swh/scheduler/task.py @@ -28,6 +28,10 @@ _statsd = None _log = None + reject_on_worker_lost = None + """Inherited from :class:`celery.app.task.Task`, but we need to override + its docstring because it uses a custom ReST role""" + @property def statsd(self): if self._statsd: