summaryrefslogtreecommitdiff
path: root/src/srht_contrib/jobs/poller.py
diff options
context:
space:
mode:
authorChristian Cleberg <[email protected]>2026-04-11 21:32:49 -0500
committerChristian Cleberg <[email protected]>2026-04-11 21:32:49 -0500
commit533866679755bd6e7a97cfa0f050eaa832b0b373 (patch)
tree8f2ca7dd89661be972cd5750ed991862aa0fe8da /src/srht_contrib/jobs/poller.py
parentfe5efeb33639e963029c3a118ccc2e98bafccb58 (diff)
downloadhutch-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.py12
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