mirror of
https://github.com/rennf93/roboco.git
synced 2026-08-03 07:23:24 +02:00
33 lines
881 B
Python
33 lines
881 B
Python
|
"""Add ix_tasks_source_status_created — bounded video render-loop scan.
|
||
|
|
|
||
|
|
``list_completed_video_tasks`` is bounded by ``.order_by(created_at.desc()
|
||
|
|
).limit(video_render_scan_limit)``; the composite ``(source, status,
|
||
|
|
created_at)`` index backs that bounded scan so it doesn't read the growing
|
||
|
|
completed-history set. Additive; no data change.
|
||
|
|
|
||
|
|
Revision ID: 066_tasks_source_status_idx
|
||
|
|
Revises: 065_rag_index_failures
|
||
|
|
Create Date: 2026-07-06
|
||
|
|
"""
|
||
|
|
|
||
|
|
from __future__ import annotations
|
||
|
|
|
||
|
|
from alembic import op
|
||
|
|
|
||
|
|
revision = "066_tasks_source_status_idx"
|
||
|
|
down_revision = "065_rag_index_failures"
|
||
|
|
branch_labels = None
|
||
|
|
depends_on = None
|
||
|
|
|
||
|
|
|
||
|
|
def upgrade() -> None:
|
||
|
|
op.create_index(
|
||
|
|
"ix_tasks_source_status_created",
|
||
|
|
"tasks",
|
||
|
|
["source", "status", "created_at"],
|
||
|
|
)
|
||
|
|
|
||
|
|
|
||
|
|
def downgrade() -> None:
|
||
|
|
op.drop_index("ix_tasks_source_status_created", table_name="tasks")
|