fmt

broadinstitute · Nov 10, 2020 · 79f1c81 · 79f1c81
1 parent 073156a
commit 79f1c81
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/google2/src/main/scala/org/broadinstitute/dsde/workbench/google2/GooglePublisher.scala b/google2/src/main/scala/org/broadinstitute/dsde/workbench/google2/GooglePublisher.scala
@@ -21,9 +21,9 @@ trait GooglePublisher[F[_]] {
   def publishNative: Pipe[F, PubsubMessage, Unit]
 
   /**
-    * Watch out message size quota and limitations https://cloud.google.com/pubsub/quotas
-    * This publishes a single message, but the preferred approach is with streams via `publish`
-    */
+   * Watch out message size quota and limitations https://cloud.google.com/pubsub/quotas
+   * This publishes a single message, but the preferred approach is with streams via `publish`
+   */
   def publishOne[MessageType: Encoder](message: MessageType)(implicit ev: Ask[F, TraceId]): F[Unit]
 
   /**

diff --git a/...src/main/scala/org/broadinstitute/dsde/workbench/google2/GooglePublisherInterpreter.scala b/...src/main/scala/org/broadinstitute/dsde/workbench/google2/GooglePublisherInterpreter.scala
@@ -54,7 +54,7 @@ private[google2] class GooglePublisherInterpreter[F[_]: Async: Timer: Structured
 
   override def publishOne[MessageType: Encoder](message: MessageType)(implicit ev: Ask[F, TraceId]): F[Unit] = {
     val byteString = ByteString.copyFromUtf8(message.asJson.noSpaces)
-    tracedLogging(asyncPublishMessage(byteString),s"com.google.cloud.pubsub.v1.Publisher.publish($byteString)")
+    tracedLogging(asyncPublishMessage(byteString), s"com.google.cloud.pubsub.v1.Publisher.publish($byteString)")
   }
 
   private def publishMessage(message: String, traceId: Option[TraceId]): Stream[F, Unit] = {