diff options
| author | Christian Cleberg <[email protected]> | 2026-04-11 21:32:49 -0500 |
|---|---|---|
| committer | Christian Cleberg <[email protected]> | 2026-04-11 21:32:49 -0500 |
| commit | 533866679755bd6e7a97cfa0f050eaa832b0b373 (patch) | |
| tree | 8f2ca7dd89661be972cd5750ed991862aa0fe8da /src/srht_contrib/jobs/poller.py | |
| parent | fe5efeb33639e963029c3a118ccc2e98bafccb58 (diff) | |
| download | hutch-stats-533866679755bd6e7a97cfa0f050eaa832b0b373.tar.gz hutch-stats-533866679755bd6e7a97cfa0f050eaa832b0b373.tar.bz2 hutch-stats-533866679755bd6e7a97cfa0f050eaa832b0b373.zip | |
fix: reduce sr.ht poll API load with cached repo discovery
Diffstat (limited to 'src/srht_contrib/jobs/poller.py')
| -rw-r--r-- | src/srht_contrib/jobs/poller.py | 12 |
1 files changed, 1 insertions, 11 deletions
diff --git a/src/srht_contrib/jobs/poller.py b/src/srht_contrib/jobs/poller.py index 94a7d96..b2fe70f 100644 --- a/src/srht_contrib/jobs/poller.py +++ b/src/srht_contrib/jobs/poller.py @@ -91,7 +91,6 @@ class PollerService: inserted = 0 inserted += self._poll_service(db, actor, self.todo_service.service_name, self.todo_service.fetch_recent_events) self._sync_tracked_repositories(db, actor) - git_repositories = self._tracked_repositories_for_actor(db, actor) inserted += self._poll_service( db, actor, @@ -99,7 +98,7 @@ class PollerService: lambda actor, since: self.git_service.fetch_recent_events( actor=actor, since=since, - repositories=git_repositories, + db=db, ), ) return inserted @@ -172,15 +171,6 @@ class PollerService: ) db.flush() - def _tracked_repositories_for_actor(self, db: Session, actor: str) -> list[str]: - rows = db.scalars( - select(TrackedRepository.repo_name) - .where(TrackedRepository.service == self.git_service.service_name) - .where(TrackedRepository.actor == actor) - .order_by(TrackedRepository.repo_name) - ).all() - return list(rows) - def _update_tracked_actor_poll_state(self, db: Session, actor: str, status: str, error: str | None) -> None: tracked_actor = self.track_actor_request(db, actor, update_last_requested=False) tracked_actor.last_poll_status = status |
