DataOps-platform/tests/test_phase3_wp06_subscription_migration_contract.py

from __future__ import annotations

import importlib


def test_wp06_subscription_migration_is_chained_after_lifecycle_and_has_durable_queue_tables():
    migration = importlib.import_module("migrations.versions.20260811_483_trusted_delivery_subscriptions")

    assert migration.revision == "20260811_483"
    assert migration.down_revision == "20260811_482"
    source = migration.upgrade.__code__.co_consts
    assert any("trusted_delivery_subscriptions" in value and "trusted_delivery_subscription_deliveries" in value for value in source if isinstance(value, str))