vikarti.anatra/Skyvern
1
0
Fork 0
mirror of https://github.com/Skyvern-AI/skyvern.git synced 2026-07-09 16:09:13 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

fix(runs): show scheduled workflow runs on global /runs page (SKY-8937) (#5949)

Browse source 
Co-authored-by: pedrohsdb <pedro@skyvern.com>
This commit is contained in:
Aaron Perez 2026-05-12 19:14:00 -05:00 • committed by GitHub
parent d4ca1e4e7a
commit 0a771321d5
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 54 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

54
alembic/versions/2026_05_11_2257-43e7421f40f8_drop_status_is_not_null_predicate_from_ix_task_runs_org_toplevel_created.py Normal file
View file

@ -0,0 +1,54 @@
"""drop status IS NOT NULL predicate from ix_task_runs_org_toplevel_created
Revision ID: 43e7421f40f8
Revises: 78a8db531e69
Create Date: 2026-05-11T22:57:56.158938+00:00
"""
from typing import Sequence, Union
from alembic import op
# revision identifiers, used by Alembic.
revision: str = "43e7421f40f8"
down_revision: Union[str, None] = "d8f04a23d52b"
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None
def upgrade() -> None:
with op.get_context().autocommit_block():
op.execute("SET statement_timeout = '3h';")
try:
op.execute("DROP INDEX CONCURRENTLY IF EXISTS ix_task_runs_org_toplevel_created")
op.execute("""
CREATE INDEX CONCURRENTLY IF NOT EXISTS ix_task_runs_org_toplevel_created
ON task_runs (organization_id, created_at DESC)
WHERE parent_workflow_run_id IS NULL
AND debug_session_id IS NULL;
""")
finally:
try:
op.execute("RESET statement_timeout;")
except Exception:
pass # Don't mask the original index op error
def downgrade() -> None:
with op.get_context().autocommit_block():
op.execute("SET statement_timeout = '3h';")
try:
op.execute("DROP INDEX CONCURRENTLY IF EXISTS ix_task_runs_org_toplevel_created")
op.execute("""
CREATE INDEX CONCURRENTLY IF NOT EXISTS ix_task_runs_org_toplevel_created
ON task_runs (organization_id, created_at DESC)
WHERE parent_workflow_run_id IS NULL
AND debug_session_id IS NULL
AND status IS NOT NULL;
""")
finally:
try:
op.execute("RESET statement_timeout;")
except Exception:
pass # Don't mask the original index op error