risingwave_meta_model_migration/
m20251126_093529_add_is_iceberg_compactor.rs

1use sea_orm_migration::prelude::*;
2
3#[derive(DeriveMigrationName)]
4pub struct Migration;
5
6#[async_trait::async_trait]
7impl MigrationTrait for Migration {
8    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
9        manager
10            .alter_table(
11                Table::alter()
12                    .table(WorkerProperty::Table)
13                    .add_column(
14                        ColumnDef::new(WorkerProperty::IsIcebergCompactor)
15                            .boolean()
16                            .not_null()
17                            .default(false),
18                    )
19                    .to_owned(),
20            )
21            .await
22    }
23
24    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
25        manager
26            .alter_table(
27                Table::alter()
28                    .table(WorkerProperty::Table)
29                    .drop_column(WorkerProperty::IsIcebergCompactor)
30                    .to_owned(),
31            )
32            .await
33    }
34}
35
36#[derive(DeriveIden)]
37enum WorkerProperty {
38    Table,
39    IsIcebergCompactor,
40}