diff --git a/crates/db/src/connection/conn_impl.rs b/crates/db/src/connection/conn_impl.rs
index 25c00cd4..fe205b1f 100644
--- a/crates/db/src/connection/conn_impl.rs
+++ b/crates/db/src/connection/conn_impl.rs
@@ -817,8 +817,8 @@ impl UserConnection {
                     user_id,
                     msg,
                     pubkey,
-                    flow_run_id,
-                ) VALUES ($1, $2, $3) RETURNING id",
+                    flow_run_id
+                ) VALUES ($1, $2, $3, $4) RETURNING id",
             )
             .await
             .map_err(Error::exec("prepare"))?;