From 6149ca9c394df7d316f80db05ad0fc2aea6c550d Mon Sep 17 00:00:00 2001 From: Christian Cleberg Date: Sat, 11 Apr 2026 13:58:01 -0500 Subject: feat: add lazy actor indexing for contribution lookups --- alembic/versions/20260411_0002_tracked_actors.py | 39 ++++++++++++++++++++++++ 1 file changed, 39 insertions(+) create mode 100644 alembic/versions/20260411_0002_tracked_actors.py (limited to 'alembic') 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") -- cgit v1.2.3