Catalyst / admin/Synapse-Cortex 14.8 GB / 57.8 GB 40.0 GB free
Help Sign in

admin / Synapse-Cortex

public

Self Hosted ITSM Tool with RBAC/Tenanting and MFA

Code Issues Pull requests Pipelines Packages Security Insights Wiki Settings
Synapse-Cortex / Synapse-Cortexv2 / alembic / versions / c4d8e2f6a9b1_remediation_runs.py 2722 B · main 
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
"""remediation runs

Revision ID: c4d8e2f6a9b1
Revises: 9b2f4a7c1d3e
Create Date: 2026-07-07 10:05:00.000000

"""
from typing import Sequence, Union

from alembic import op
import sqlalchemy as sa
from sqlalchemy.dialects import postgresql

# revision identifiers, used by Alembic.
revision: str = 'c4d8e2f6a9b1'
down_revision: Union[str, None] = '9b2f4a7c1d3e'
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None


def upgrade() -> None:
    bind = op.get_bind()

    run_status = postgresql.ENUM(
        "investigating", "pending_approval", "executing", "succeeded", "failed", "rejected", "blocked",
        name="remediation_run_status", create_type=False,
    )
    run_status.create(bind, checkfirst=True)

    op.create_table(
        "remediation_runs",
        sa.Column("id", postgresql.UUID(as_uuid=True), primary_key=True),
        sa.Column("tenant_id", postgresql.UUID(as_uuid=True), sa.ForeignKey("tenants.id", ondelete="CASCADE"), nullable=False),
        sa.Column("ticket_id", postgresql.UUID(as_uuid=True), sa.ForeignKey("tickets.id", ondelete="CASCADE"), nullable=False),
        sa.Column("playbook_id", postgresql.UUID(as_uuid=True), sa.ForeignKey("playbooks.id", ondelete="SET NULL"), nullable=True),
        sa.Column("status", run_status, nullable=False, server_default=sa.text("'investigating'")),
        sa.Column("ai_summary", sa.Text(), nullable=True),
        sa.Column("proposed_plan", sa.JSON(), nullable=True),
        sa.Column("execution_log", sa.JSON(), nullable=True),
        sa.Column("outcome_summary", sa.Text(), nullable=True),
        sa.Column("approved_by_id", postgresql.UUID(as_uuid=True), sa.ForeignKey("users.id", ondelete="SET NULL"), nullable=True),
        sa.Column("approved_at", sa.DateTime(timezone=True), nullable=True),
        sa.Column("playbook_name_snapshot", sa.String(120), nullable=True),
        sa.Column("guardrails_snapshot", sa.JSON(), nullable=True),
        sa.Column("graph_snapshot", sa.JSON(), nullable=True),
        sa.Column("created_by_id", postgresql.UUID(as_uuid=True), sa.ForeignKey("users.id", ondelete="SET NULL"), nullable=True),
        sa.Column("created_at", sa.DateTime(timezone=True), server_default=sa.func.now()),
        sa.Column("updated_at", sa.DateTime(timezone=True), server_default=sa.func.now()),
    )
    op.create_index("ix_remediation_runs_ticket_created", "remediation_runs", ["ticket_id", "created_at"])


def downgrade() -> None:
    bind = op.get_bind()

    op.drop_index("ix_remediation_runs_ticket_created", table_name="remediation_runs")
    op.drop_table("remediation_runs")

    postgresql.ENUM(name="remediation_run_status").drop(bind, checkfirst=True)