diff --git a/src/ingestion/db.rs b/src/ingestion/db.rs
index 720b40b..3123308 100644
--- a/src/ingestion/db.rs
+++ b/src/ingestion/db.rs
@@ -108,7 +108,7 @@ async fn notify_new_transactions(
 ) -> Result<(), AppError> {
     let payload = serde_json::to_string(&new_transaction_ids).map_err(|e| anyhow!(e))?;
 
-    db.execute_unprepared(&format!(r#"NOTIFY monzo_new_transactions, {payload}"#,))
+    db.execute_unprepared(&format!(r#"NOTIFY monzo_new_transactions, '{payload}'"#,))
         .await?;
 
     Ok(())