risingwave_meta_model_migration/
m20251215_000000_streaming_job_parallelism_strategy.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(StreamingJob::Table)
13                    .add_column(
14                        ColumnDef::new(StreamingJob::AdaptiveParallelismStrategy)
15                            .string()
16                            .null(),
17                    )
18                    .to_owned(),
19            )
20            .await
21    }
22
23    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
24        manager
25            .alter_table(
26                Table::alter()
27                    .table(StreamingJob::Table)
28                    .drop_column(StreamingJob::AdaptiveParallelismStrategy)
29                    .to_owned(),
30            )
31            .await
32    }
33}
34
35#[derive(DeriveIden)]
36enum StreamingJob {
37    Table,
38    AdaptiveParallelismStrategy,
39}