Skip to content

Commit

Permalink
Merge pull request #14995 from kw2542/BEAM-12419
Browse files Browse the repository at this point in the history
[BEAM-12419] Deadline should be reset for each gRPC call.
  • Loading branch information
ibzib authored Jun 11, 2021
2 parents a834f2d + eb65b1b commit c0b8e65
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -153,7 +153,7 @@ private void waitForTerminalState() {
Thread.currentThread().interrupt();
throw new RuntimeException(e);
}
response = stub.getState(request);
response = stub.withDeadlineAfter(jobServerTimeout, TimeUnit.SECONDS).getState(request);
lastState = getJavaState(response.getState());
}
terminalState = lastState;
Expand Down

0 comments on commit c0b8e65

Please sign in to comment.