Move emit to end of transaction (#760)

jamsocket · Jun 25, 2024 · 6fe95a8 · 6fe95a8
1 parent cc3fabd
commit 6fe95a8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/plane/src/database/backend.rs b/plane/src/database/backend.rs
@@ -185,8 +185,6 @@ impl<'a> BackendDatabase<'a> {
     ) -> sqlx::Result<bool> {
         let mut txn = self.db.pool.begin().await?;
 
-        emit_with_key(&mut *txn, &backend.to_string(), &new_state).await?;
-
         let new_status = new_state.status();
         let new_status_number = new_status.as_int();
 
@@ -255,6 +253,8 @@ impl<'a> BackendDatabase<'a> {
             .await?;
         }
 
+        emit_with_key(&mut *txn, &backend.to_string(), &new_state).await?;
+
         txn.commit().await?;
 
         Ok(true)