chore: apply suggestions from CR

GreptimeTeam · Apr 29, 2024 · 2590213 · 2590213
1 parent 6c286be
commit 2590213
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/src/common/meta/src/ddl/create_flow/metadata.rs b/src/common/meta/src/ddl/create_flow/metadata.rs
@@ -21,7 +21,7 @@ use crate::key::table_name::TableNameKey;
 impl CreateFlowProcedure {
  /// Allocates the [FlowTaskId].
  pub(crate) async fn allocate_flow_task_id(&mut self) -> Result<()> {
- //TODO(weny, ruihang): We doesn't support the partitions. It's always be 1, now.
+ //TODO(weny, ruihang): We don't support the partitions. It's always be 1, now.
  let partitions = 1;
  let (flow_task_id, peers) = self
  .context
@@ -37,7 +37,6 @@ impl CreateFlowProcedure {
  /// Collects source table ids
  pub(crate) async fn collect_source_tables(&mut self) -> Result<()> {
  // Ensures all source tables exist.
-
  let keys = self
  .data
  .task

diff --git a/src/common/meta/src/error.rs b/src/common/meta/src/error.rs
@@ -241,7 +241,7 @@ pub enum Error {
  location: Location,
  },
 
- #[snafu(display("Task already exists, task: {}", task_name,))]
+ #[snafu(display("Task already exists: {}", task_name))]
  TaskAlreadyExists {
  task_name: String,
  location: Location,