text: from infi.clickhouse_orm import migrations
  
  from ee.clickhouse.sql.person import KAFKA_PERSONS_TABLE_SQL, PERSONS_TABLE_MV_SQL
  from posthog.settings import CLICKHOUSE_CLUSTER
  
  operations = [
      migrations.RunSQL(f"DROP TABLE person_mv ON CLUSTER '{CLICKHOUSE_CLUSTER}'"),
      migrations.RunSQL(f"DROP TABLE kafka_person ON CLUSTER '{CLICKHOUSE_CLUSTER}'"),
      migrations.RunSQL(
          f"ALTER TABLE person ON CLUSTER '{CLICKHOUSE_CLUSTER}' ADD COLUMN IF NOT EXISTS distinct_ids Array(VARCHAR)"
      ),
      migrations.RunSQL(KAFKA_PERSONS_TABLE_SQL()),
      migrations.RunSQL(PERSONS_TABLE_MV_SQL),
  ]
  