Skip to content
This repository was archived by the owner on Apr 8, 2024. It is now read-only.

Commit 3d751f3

Browse files
authored
Merge pull request #153 from jwulf/0.23.0-alpha.4
0.23.0 alpha.4
2 parents 6931a01 + def7fe4 commit 3d751f3

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "zeebe-node",
3-
"version": "v0.23.0-alpha.3",
3+
"version": "v0.23.0-alpha.4",
44
"description": "A Node.js client library for the Zeebe Microservices Orchestration Engine.",
55
"keywords": [
66
"zeebe",

src/lib/GrpcClient.ts

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -452,8 +452,9 @@ export class GrpcClient extends EventEmitter {
452452
MiddlewareSignals.Log.Error,
453453
`Grpc Channel State: ${connectivityState[state]}`
454454
)
455+
const delay = state === GrpcState.TRANSIENT_FAILURE ? 5 : 30
455456
const deadline = new Date().setSeconds(
456-
new Date().getSeconds() + 300
457+
new Date().getSeconds() + delay
457458
)
458459
if (state === GrpcState.IDLE || state === GrpcState.READY) {
459460
return resolve(state)
@@ -483,7 +484,8 @@ export class GrpcClient extends EventEmitter {
483484
)
484485
if (
485486
newState === GrpcState.READY ||
486-
newState === GrpcState.IDLE
487+
newState === GrpcState.IDLE ||
488+
newState === GrpcState.TRANSIENT_FAILURE
487489
) {
488490
return resolve(newState)
489491
} else {

0 commit comments

Comments
 (0)