diff --git a/scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/SpannerIO.scala b/scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/SpannerIO.scala
index 31ea99a069..45e7fc5752 100644
--- a/scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/SpannerIO.scala
+++ b/scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/SpannerIO.scala
@@ -102,16 +102,16 @@ final case class SpannerWrite(config: SpannerConfig) extends SpannerIO[Mutation]
   override type ReadP = Nothing
   override type WriteP = SpannerWrite.WriteParam
 
-  override protected def write(data: SCollection[Mutation], params: WriteP): Tap[Nothing] = {
-    val transform = BSpannerIO
-      .write()
-      .withSpannerConfig(config)
-      .withBatchSizeBytes(params.batchSizeBytes)
-      .withFailureMode(params.failureMode)
-
-    data.applyInternal(transform)
-    EmptyTap
-  }
+ override protected def write(data: SCollection[Mutation], params: WriteP): Tap[Nothing] = {
+  val transform = BSpannerIO
+    .write()
+    .withSpannerConfig(config)
+    .withBatchSizeBytes(params.batchSizeBytes)
+    .withFailureMode(params.failureMode)
+
+  data.applyInternal(transform)
+  EmptyTap
+}
 
   override protected def read(sc: ScioContext, params: ReadP): SCollection[Mutation] = sc.wrap {
     throw new UnsupportedOperationException("SpannerWrite is write-only")