diff --git a/router2/src/dml_handlers/schema_validation.rs b/router2/src/dml_handlers/schema_validation.rs
index eadad55c28..7eafa384ac 100644
--- a/router2/src/dml_handlers/schema_validation.rs
+++ b/router2/src/dml_handlers/schema_validation.rs
@@ -186,9 +186,7 @@ where
         self.inner
             .write(namespace, batches, span_ctx)
             .await
-            .map_err(|e| SchemaError::Inner(Box::new(e.into())))?;
-
-        Ok(())
+            .map_err(|e| SchemaError::Inner(Box::new(e.into())))
     }
 
     /// This call is passed through to `D` - no schema validation is performed