rename symbol

Signed-off-by: Ruihang Xia <[email protected]>
GreptimeTeam · Apr 28, 2024 · 2cf076b · 2cf076b
1 parent 05a046d
commit 2cf076b
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/common/meta/src/rpc/ddl.rs b/src/common/meta/src/rpc/ddl.rs
@@ -724,7 +724,7 @@ impl TryFrom<DropDatabaseTask> for PbDropDatabaseTask {
 }
 
 /// Create flow task
-pub struct CreateFlowTask {
+pub struct CreateFlow {
     pub catalog_name: String,
     pub task_name: String,
     pub source_table_names: Vec<TableName>,
@@ -737,7 +737,7 @@ pub struct CreateFlowTask {
     pub options: HashMap<String, String>,
 }
 
-impl TryFrom<PbCreateFlowTask> for CreateFlowTask {
+impl TryFrom<PbCreateFlowTask> for CreateFlow {
     type Error = error::Error;
 
     fn try_from(pb: PbCreateFlowTask) -> Result<Self> {
@@ -756,7 +756,7 @@ impl TryFrom<PbCreateFlowTask> for CreateFlowTask {
             err_msg: "expected create_flow_task",
         })?;
 
-        Ok(CreateFlowTask {
+        Ok(CreateFlow {
             catalog_name,
             task_name,
             source_table_names: source_table_names.into_iter().map(Into::into).collect(),
@@ -775,9 +775,9 @@ impl TryFrom<PbCreateFlowTask> for CreateFlowTask {
     }
 }
 
-impl From<CreateFlowTask> for PbCreateFlowTask {
+impl From<CreateFlow> for PbCreateFlowTask {
     fn from(
-        CreateFlowTask {
+        CreateFlow {
             catalog_name,
             task_name,
             source_table_names,
@@ -788,7 +788,7 @@ impl From<CreateFlowTask> for PbCreateFlowTask {
             comment,
             sql,
             options,
-        }: CreateFlowTask,
+        }: CreateFlow,
     ) -> Self {
         PbCreateFlowTask {
             create_flow_task: Some(CreateFlowTaskExpr {