risingwave_meta_model_migration/
m20250905_144810_deprecate_table_incoming_sinks.rs

1use sea_orm_migration::prelude::{Table as MigrationTable, *};
2#[derive(DeriveMigrationName)]
3pub struct Migration;
4
5#[async_trait::async_trait]
6impl MigrationTrait for Migration {
7    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
8        manager
9            .alter_table(
10                MigrationTable::alter()
11                    .table(Table::Table)
12                    .drop_column(Table::IncomingSinks)
13                    .to_owned(),
14            )
15            .await
16    }
17
18    async fn down(&self, _manager: &SchemaManager) -> Result<(), DbErr> {
19        Ok(())
20    }
21}
22
23#[derive(DeriveIden)]
24#[allow(clippy::enum_variant_names)]
25enum Table {
26    Table,
27    IncomingSinks,
28}