summaryrefslogtreecommitdiff
path: root/alembic/versions
diff options
context:
space:
mode:
authorChristian Cleberg <[email protected]>2026-04-11 13:58:01 -0500
committerChristian Cleberg <[email protected]>2026-04-11 13:58:01 -0500
commit6149ca9c394df7d316f80db05ad0fc2aea6c550d (patch)
tree11f6cebc445e14b4a79adae648eb46d4be710071 /alembic/versions
parentb6d1348abf907b8b9c16ab87487eb9384dc4cc89 (diff)
downloadhutch-stats-6149ca9c394df7d316f80db05ad0fc2aea6c550d.tar.gz
hutch-stats-6149ca9c394df7d316f80db05ad0fc2aea6c550d.tar.bz2
hutch-stats-6149ca9c394df7d316f80db05ad0fc2aea6c550d.zip
feat: add lazy actor indexing for contribution lookups
Diffstat (limited to 'alembic/versions')
-rw-r--r--alembic/versions/20260411_0002_tracked_actors.py39
1 files changed, 39 insertions, 0 deletions
diff --git a/alembic/versions/20260411_0002_tracked_actors.py b/alembic/versions/20260411_0002_tracked_actors.py
new file mode 100644
index 0000000..e3f0e31
--- /dev/null
+++ b/alembic/versions/20260411_0002_tracked_actors.py
@@ -0,0 +1,39 @@
+"""tracked actors for lazy indexing"""
+
+from __future__ import annotations
+
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy import inspect
+
+
+revision = "20260411_0002"
+down_revision = "20260409_0001"
+branch_labels = None
+depends_on = None
+
+
+def _table_names() -> set[str]:
+ return set(inspect(op.get_bind()).get_table_names())
+
+
+def upgrade() -> None:
+ if "tracked_actors" in _table_names():
+ return
+
+ op.create_table(
+ "tracked_actors",
+ sa.Column("id", sa.Integer(), primary_key=True),
+ sa.Column("actor", sa.String(length=255), nullable=False),
+ sa.Column("is_active", sa.Boolean(), nullable=False, server_default=sa.true()),
+ sa.Column("last_requested_at", sa.DateTime(timezone=True), nullable=True),
+ sa.Column("last_polled_at", sa.DateTime(timezone=True), nullable=True),
+ sa.Column("last_poll_status", sa.String(length=32), nullable=True),
+ sa.Column("last_poll_error", sa.Text(), nullable=True),
+ sa.UniqueConstraint("actor", name="uq_tracked_actor_actor"),
+ )
+
+
+def downgrade() -> None:
+ if "tracked_actors" in _table_names():
+ op.drop_table("tracked_actors")