diff --git a/src/merger/mod.rs b/src/merger/mod.rs
index b04bcac..61597e5 100644
--- a/src/merger/mod.rs
+++ b/src/merger/mod.rs
@@ -951,6 +951,7 @@ impl Merger {
     let mut notification = serde_json::Map::new();
     notification.insert("complete".to_string(), Value::Object(complete));
     notification.insert("new".to_string(), new_val_obj.clone());
+    notification.insert("kind".to_string(), Value::String(change_kind.to_string()));
 
     if old_val_obj != Value::Null {
       notification.insert("old".to_string(), old_val_obj.clone());
diff --git a/src/tests/types/expect/sql.rs b/src/tests/types/expect/sql.rs
index d1384b3..f21baff 100644
--- a/src/tests/types/expect/sql.rs
+++ b/src/tests/types/expect/sql.rs
@@ -11,6 +11,7 @@ impl Expect {
         return Err(e);
       }
     }
+    self.assert_pattern(actual)?;
     Ok(())
   }