no concurrency

broadinstitute · Jan 6, 2021 · c79fb91 · c79fb91
1 parent efc7510
commit c79fb91
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...cala/org/broadinstitute/dsde/workbench/sam/backgroundProcess/CryptominingSubscriber.scala b/...cala/org/broadinstitute/dsde/workbench/sam/backgroundProcess/CryptominingSubscriber.scala
@@ -16,7 +16,7 @@ class CryptominingSubscriber(subscriber: GoogleSubscriber[IO, CryptominingUserMe
                              userService: UserService
                             )(implicit logger: StructuredLogger[IO], cs: ContextShift[IO]) {
   val process: Stream[IO, Unit] = subscriber.messages
-    .parEvalMapUnordered(2)(messageHandler) // concurrency is low since we don't need high performance in disabling cryptomining users.
+    .evalMap(messageHandler)
     .handleErrorWith(error => Stream.eval(logger.error(error)("Failed to initialize message processor")))
 
   private def messageHandler(event: Event[CryptominingUserMessage]): IO[Unit] = {