diff --git a/tests/test_database.py b/tests/test_database.py
index 35923c0b..a9728019 100644
--- a/tests/test_database.py
+++ b/tests/test_database.py
@@ -116,7 +116,7 @@ async def test_execute_write_fn_block_false(app_client):
 
     def write_fn(conn):
         with conn:
-            conn.execute("delete from roadside_attractions where id = 1;")
+            conn.execute("delete from roadside_attractions where pk = 1;")
             row = conn.execute("select count(*) from roadside_attractions").fetchone()
             print("row = ", row)
         return row[0]