diff options
| author | Christian Cleberg <[email protected]> | 2026-04-11 13:58:01 -0500 |
|---|---|---|
| committer | Christian Cleberg <[email protected]> | 2026-04-11 13:58:01 -0500 |
| commit | 6149ca9c394df7d316f80db05ad0fc2aea6c550d (patch) | |
| tree | 11f6cebc445e14b4a79adae648eb46d4be710071 /alembic/versions/20260411_0002_tracked_actors.py | |
| parent | b6d1348abf907b8b9c16ab87487eb9384dc4cc89 (diff) | |
| download | hutch-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/20260411_0002_tracked_actors.py')
| -rw-r--r-- | alembic/versions/20260411_0002_tracked_actors.py | 39 |
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") |
