Leopoldadmin/leocrm
1
0
Fork 0
Code Issues 363 Pull Requests Actions Packages Projects Releases 1 Wiki Activity

fix: migration 0128 uses IF NOT EXISTS to avoid DuplicateTableError

Browse Source
This commit is contained in:
Agent Zero
2026-08-19 16:30:27 +02:00
parent 8ee88d9b41
commit 8c78d5711b
1 changed files with 21 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files
alembic/versions/0128_ai_decision_records.py
+21 -18
View File
@@ -15,24 +15,27 @@ depends_on = None
def upgrade() -> None: def upgrade() -> None:
op.create_table( # Use IF NOT EXISTS to avoid DuplicateTableError if table was already
"ai_decision_records", # created by Base.metadata.create_all() in prestart.sh
sa.Column("id", UUID(as_uuid=True), primary_key=True, server_default=sa.text("gen_random_uuid()")), op.execute("""
sa.Column("tenant_id", UUID(as_uuid=True), sa.ForeignKey("tenants.id", ondelete="CASCADE"), nullable=False, index=True), CREATE TABLE IF NOT EXISTS ai_decision_records (
sa.Column("owner_id", UUID(as_uuid=True), nullable=True, index=True), id UUID NOT NULL DEFAULT gen_random_uuid() PRIMARY KEY,
sa.Column("agent_run_id", UUID(as_uuid=True), nullable=False, index=True), tenant_id UUID NOT NULL REFERENCES tenants(id) ON DELETE CASCADE,
sa.Column("recommendation", sa.Text, nullable=False), owner_id UUID,
sa.Column("evidence", JSONB, nullable=False, server_default=sa.text("'{}'")), agent_run_id UUID NOT NULL,
sa.Column("reviewer_id", UUID(as_uuid=True), nullable=True), recommendation TEXT NOT NULL,
sa.Column("decision", sa.String(20), nullable=True), evidence JSONB NOT NULL DEFAULT '{}',
sa.Column("decision_timestamp", sa.String(40), nullable=True), reviewer_id UUID,
sa.Column("deviation_note", sa.Text, nullable=True), decision VARCHAR(20),
sa.Column("created_at", sa.TIMESTAMP(timezone=True), server_default=sa.text("now()"), nullable=False), decision_timestamp VARCHAR(40),
sa.Column("updated_at", sa.TIMESTAMP(timezone=True), server_default=sa.text("now()"), nullable=False), deviation_note TEXT,
sa.Column("deleted_at", sa.TIMESTAMP(timezone=True), nullable=True), created_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL,
) updated_at TIMESTAMP WITH TIME ZONE DEFAULT now() NOT NULL,
op.create_index("ix_ai_decision_records_tenant_id", "ai_decision_records", ["tenant_id"]) deleted_at TIMESTAMP WITH TIME ZONE
op.create_index("ix_ai_decision_records_agent_run_id", "ai_decision_records", ["agent_run_id"]) )
""")
op.execute("CREATE INDEX IF NOT EXISTS ix_ai_decision_records_tenant_id ON ai_decision_records(tenant_id)")
op.execute("CREATE INDEX IF NOT EXISTS ix_ai_decision_records_agent_run_id ON ai_decision_records(agent_run_id)")
def downgrade() -> None: def downgrade() -> None: