22 lines
664 B
Python
22 lines
664 B
Python
|
"""add persistent outbox delivery deduplication"""
|
||
|
|
from alembic import op
|
||
|
|
|
||
|
|
revision = "20260909_outbox_delivery"
|
||
|
|
down_revision = "20260909_agent_platform_v31"
|
||
|
|
branch_labels = None
|
||
|
|
depends_on = None
|
||
|
|
|
||
|
|
|
||
|
|
def upgrade() -> None:
|
||
|
|
op.execute("""CREATE TABLE outbox_delivery (
|
||
|
|
id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
|
||
|
|
event_id CHAR(36) NOT NULL,
|
||
|
|
consumer_name VARCHAR(64) NOT NULL,
|
||
|
|
delivered_at DATETIME(6) NOT NULL,
|
||
|
|
PRIMARY KEY (id), UNIQUE KEY uk_outbox_delivery_event_consumer (event_id, consumer_name)
|
||
|
|
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4""")
|
||
|
|
|
||
|
|
|
||
|
|
def downgrade() -> None:
|
||
|
|
op.execute("DROP TABLE outbox_delivery")
|