Skip to content


fix: deflake SubscriptionPartitionProcessorImplTest (#768)
Browse files Browse the repository at this point in the history
The test case expects the processor to fail immediately (with deadline of zero) after failing the underlying subscriber. However, the actual failing is done asynchronously. Waiting for a little bit removes the flakiness.

Co-authored-by: Manu Menzella <>
  • Loading branch information
manuelmenzella-google and Manu Menzella committed Jul 28, 2021
1 parent 236f251 commit c34e430
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ public void subscriberFailureFails() throws Exception {
processor.start(); CheckedApiException(Code.OUT_OF_RANGE));
ApiException e =
assertThrows(ApiException.class, () -> processor.waitForCompletion(Duration.ZERO));
assertThrows(ApiException.class, () -> processor.waitForCompletion(Duration.millis(10)));
assertEquals(Code.OUT_OF_RANGE, e.getStatusCode().getCode());

Expand Down

0 comments on commit c34e430

Please sign in to comment.