diff --git a/query-engine/connector-test-kit-rs/query-engine-tests/tests/writes/top_level_mutations/create_many_and_return.rs b/query-engine/connector-test-kit-rs/query-engine-tests/tests/writes/top_level_mutations/create_many_and_return.rs
index a55efb4e0cc9..f02aaf81e600 100644
--- a/query-engine/connector-test-kit-rs/query-engine-tests/tests/writes/top_level_mutations/create_many_and_return.rs
+++ b/query-engine/connector-test-kit-rs/query-engine-tests/tests/writes/top_level_mutations/create_many_and_return.rs
@@ -232,7 +232,8 @@ mod create_many {
     // Covers: Batching by row number.
     // Each DB allows a certain amount of params per single query, and a certain number of rows.
     // Each created row has 1 param and we create 1000 records.
-    #[connector_test(schema(schema_4))]
+    // TODO: unexclude d1 once https://github.com/prisma/team-orm/issues/1070 is fixed
+    #[connector_test(schema(schema_4), exclude(Sqlite("cfd1")))]
     async fn large_num_records_horizontal(runner: Runner) -> TestResult<()> {
         let mut records: Vec<String> = vec![];
 
@@ -276,7 +277,8 @@ mod create_many {
     // Covers: Batching by row number.
     // Each DB allows a certain amount of params per single query, and a certain number of rows.
     // Each created row has 4 params and we create 1000 rows.
-    #[connector_test(schema(schema_5))]
+    // TODO: unexclude d1 once https://github.com/prisma/team-orm/issues/1070 is fixed
+    #[connector_test(schema(schema_5), exclude(Sqlite("cfd1")))]
     async fn large_num_records_vertical(runner: Runner) -> TestResult<()> {
         let mut records: Vec<String> = vec![];