2-step notify

risingwavelabs · Nov 28, 2023 · 0a551e3 · 0a551e3
1 parent e3220d0
commit 0a551e3
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/meta/src/manager/catalog/mod.rs b/src/meta/src/manager/catalog/mod.rs
@@ -1990,7 +1990,7 @@ impl CatalogManager {
                             with_grant_option: false,
                             granted_by: old_owner_id,
                         }
-                    }]
+                    }],
                 };
                 if let Some(privilege) = user
                     .grant_privileges
@@ -2005,7 +2005,8 @@ impl CatalogManager {
                 commit_meta!(self, databases, users)?;
                 user_core.increase_ref(owner_id);
                 user_core.decrease_ref(old_owner_id);
-                let version = self.notify_frontend(Operation::Update, vec![relation_info, user_info]).await;
+                self.notify_frontend(Operation::Update, user_info).await;
+                let version = self.notify_frontend(Operation::Update, relation_info).await;
                 return Ok(version);
             }
             alter_owner_request::Object::SchemaId(schema_id) => {
@@ -2024,7 +2025,7 @@ impl CatalogManager {
             }
         };
 
-        let version = self.notify_frontend(Operation::Update, vec![relation_info]).await;
+        let version = self.notify_frontend(Operation::Update, relation_info).await;
 
         Ok(version)
     }