ad0284585b
Goon — self-hosted aggregator for adult-content scene metadata. Indexes scenes from TPDB, StashDB, and 30+ public adult tube sites. Cross-source deduplication via perceptual hash + Levenshtein distance. FastAPI backend + APScheduler worker + React Native (Expo) mobile client. FOSS, ad-free, donation-funded. See README for details.
42 lines
1.5 KiB
Python
42 lines
1.5 KiB
Python
"""Performer.last_searched_at + search_run_count — backfill queue dla per-performer search.
|
|
|
|
Revision ID: 0008_performer_search_meta
|
|
Revises: 0007_play_progress
|
|
Create Date: 2026-05-06
|
|
|
|
Continuous worker iteruje performerów ORDER BY last_searched_at NULLS FIRST,
|
|
search_run_count ASC. Performerów którzy nigdy nie byli searchowani idą pierwsi.
|
|
Po pełnym sweep'ie kolejka cyklicznie wraca do najstarszych.
|
|
"""
|
|
from collections.abc import Sequence
|
|
|
|
import sqlalchemy as sa
|
|
from alembic import op
|
|
|
|
revision: str = "0008_performer_search_meta"
|
|
down_revision: str | None = "0007_play_progress"
|
|
branch_labels: str | Sequence[str] | None = None
|
|
depends_on: str | Sequence[str] | None = None
|
|
|
|
|
|
def upgrade() -> None:
|
|
op.add_column(
|
|
"performers",
|
|
sa.Column("last_searched_at", sa.DateTime(timezone=True), nullable=True),
|
|
)
|
|
op.add_column(
|
|
"performers",
|
|
sa.Column("search_run_count", sa.Integer(), nullable=False, server_default="0"),
|
|
)
|
|
# Index dla queue: NULLS FIRST + search_run_count ASC. PostgreSQL btree
|
|
# default DESC ma NULLS FIRST. Asc - NULLS LAST. Robimy explicit.
|
|
op.execute(
|
|
"CREATE INDEX ix_performers_search_priority "
|
|
"ON performers (last_searched_at ASC NULLS FIRST, search_run_count ASC)"
|
|
)
|
|
|
|
|
|
def downgrade() -> None:
|
|
op.drop_index("ix_performers_search_priority", table_name="performers")
|
|
op.drop_column("performers", "search_run_count")
|
|
op.drop_column("performers", "last_searched_at")
|