fix batch consumer test timeout interruption (#36246)

GitOrigin-RevId: 3332f5e1405eba5397bfcc93174b0415f2220703
wix · Sep 3, 2023 · 00d10db · 00d10db
1 parent e57a8bd
commit 00d10db
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/core/src/it/scala/com/wixpress/dst/greyhound/core/batched/BatchedConsumerIT.scala b/core/src/it/scala/com/wixpress/dst/greyhound/core/batched/BatchedConsumerIT.scala
@@ -212,6 +212,7 @@ class BatchedConsumerIT extends BaseTestWithSharedEnv[Env, TestResources] {
               ) *>
                 barrier
                   .offer(())
+                  .interruptible
                   // we can't block here, otherwise rebalance won't happen - so we just fail
                   .timeoutFail(new RuntimeException("queue full"))(1.second)
                   .tapError(_ => ZIO.succeed(println(s"[$id] timed out waiting on barrier")))