From 3cc360c8b91183d68174d3840da2bb9d8b6e668d Mon Sep 17 00:00:00 2001
From: Ilya Bikmeev <i@ibikmeev.ru>
Date: Sat, 6 Dec 2025 13:27:57 +0500
Subject: [PATCH] fix: migrations

---
 ...l_events_table.py => 49dc6736230f_init.py} | 16 +++++----
 ...dd_unique_constraint_to_call_session_id.py | 33 -------------------
 2 files changed, 9 insertions(+), 40 deletions(-)
 rename services/ingest-service/alembic/versions/{a7e5c5ef6bc1_initial_migration_with_call_events_table.py => 49dc6736230f_init.py} (85%)
 delete mode 100644 services/ingest-service/alembic/versions/9163176d6848_add_unique_constraint_to_call_session_id.py

diff --git a/services/ingest-service/alembic/versions/a7e5c5ef6bc1_initial_migration_with_call_events_table.py b/services/ingest-service/alembic/versions/49dc6736230f_init.py
similarity index 85%
rename from services/ingest-service/alembic/versions/a7e5c5ef6bc1_initial_migration_with_call_events_table.py
rename to services/ingest-service/alembic/versions/49dc6736230f_init.py
index 2199012..50cccc5 100644
--- a/services/ingest-service/alembic/versions/a7e5c5ef6bc1_initial_migration_with_call_events_table.py
+++ b/services/ingest-service/alembic/versions/49dc6736230f_init.py
@@ -1,8 +1,8 @@
-"""Initial migration with call_events table
+"""INIT
 
-Revision ID: a7e5c5ef6bc1
+Revision ID: 49dc6736230f
 Revises: 
-Create Date: 2025-11-19 22:43:33.739763
+Create Date: 2025-12-06 13:21:32.669444
 
 """
 from typing import Sequence, Union
@@ -12,14 +12,13 @@ import sqlalchemy as sa
 
 
 # revision identifiers, used by Alembic.
-revision: str = 'a7e5c5ef6bc1'
+revision: str = '49dc6736230f'
 down_revision: Union[str, Sequence[str], None] = None
 branch_labels: Union[str, Sequence[str], None] = None
 depends_on: Union[str, Sequence[str], None] = None
 
 
 def upgrade() -> None:
-    """Upgrade schema."""
     # ### commands auto generated by Alembic - please adjust! ###
     op.create_table('call_events',
     sa.Column('id', sa.UUID(), nullable=False),
@@ -36,17 +35,20 @@ def upgrade() -> None:
     sa.Column('clean_talk_time_duration', sa.Integer(), nullable=False),
     sa.Column('full_record_file_link', sa.String(), nullable=False),
     sa.Column('tcm_topcrm_notification_name', sa.String(), nullable=False),
+    sa.Column('s3_key', sa.String(), nullable=True),
+    sa.Column('processing_status', sa.String(), nullable=False),
+    sa.Column('retries', sa.Integer(), nullable=False),
     sa.PrimaryKeyConstraint('id')
     )
-    op.create_index(op.f('ix_call_events_call_session_id'), 'call_events', ['call_session_id'], unique=False)
+    op.create_index(op.f('ix_call_events_call_session_id'), 'call_events', ['call_session_id'], unique=True)
     op.create_index(op.f('ix_call_events_id'), 'call_events', ['id'], unique=False)
     # ### end Alembic commands ###
 
 
 def downgrade() -> None:
-    """Downgrade schema."""
     # ### commands auto generated by Alembic - please adjust! ###
     op.drop_index(op.f('ix_call_events_id'), table_name='call_events')
     op.drop_index(op.f('ix_call_events_call_session_id'), table_name='call_events')
     op.drop_table('call_events')
     # ### end Alembic commands ###
+
diff --git a/services/ingest-service/alembic/versions/9163176d6848_add_unique_constraint_to_call_session_id.py b/services/ingest-service/alembic/versions/9163176d6848_add_unique_constraint_to_call_session_id.py
deleted file mode 100644
index dbaed93..0000000
--- a/services/ingest-service/alembic/versions/9163176d6848_add_unique_constraint_to_call_session_id.py
+++ /dev/null
@@ -1,33 +0,0 @@
-"""add_unique_constraint_to_call_session_id
-
-Revision ID: 9163176d6848
-Revises: a7e5c5ef6bc1
-Create Date: 2025-11-20 23:28:40.770696
-
-"""
-from typing import Sequence, Union
-
-from alembic import op
-import sqlalchemy as sa
-
-
-# revision identifiers, used by Alembic.
-revision: str = '9163176d6848'
-down_revision: Union[str, Sequence[str], None] = 'a7e5c5ef6bc1'
-branch_labels: Union[str, Sequence[str], None] = None
-depends_on: Union[str, Sequence[str], None] = None
-
-
-def upgrade() -> None:
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.drop_index(op.f('ix_call_events_call_session_id'), table_name='call_events')
-    op.create_index(op.f('ix_call_events_call_session_id'), 'call_events', ['call_session_id'], unique=True)
-    # ### end Alembic commands ###
-
-
-def downgrade() -> None:
-    # ### commands auto generated by Alembic - please adjust! ###
-    op.drop_index(op.f('ix_call_events_call_session_id'), table_name='call_events')
-    op.create_index(op.f('ix_call_events_call_session_id'), 'call_events', ['call_session_id'], unique=False)
-    # ### end Alembic commands ###
-