Skip to content

Commit e2dc2ff

Browse files
authored
Fix parsing of retry codes from config json. (#108)
1 parent ad92396 commit e2dc2ff

File tree

2 files changed

+18
-8
lines changed

2 files changed

+18
-8
lines changed

packages/packages/google-gax/lib/gax.js

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -482,8 +482,10 @@ function mergeRetryOptions(retry, overrides) {
482482
* "interfaces": {
483483
* "google.fake.v1.ServiceName": {
484484
* "retry_codes": {
485-
* "idempotent": ["UNAVAILABLE", "DEADLINE_EXCEEDED"],
486-
* "non_idempotent": []
485+
* "retry_codes_def": {
486+
* "idempotent": ["UNAVAILABLE", "DEADLINE_EXCEEDED"],
487+
* "non_idempotent": []
488+
* }
487489
* },
488490
* "retry_params": {
489491
* "default": {
@@ -554,7 +556,7 @@ exports.constructSettings = function constructSettings(
554556
var jsName = methodName[0].toLowerCase() + methodName.slice(1);
555557

556558
var retry = constructRetry(methodConfig,
557-
serviceConfig.retry_codes,
559+
serviceConfig.retry_codes.retry_codes_def,
558560
serviceConfig.retry_params,
559561
retryNames);
560562
var bundlingConfig = methodConfig.bundling;
@@ -569,9 +571,13 @@ exports.constructSettings = function constructSettings(
569571
timeout = overridingMethod.timeout_millis;
570572
}
571573
}
574+
var overridesRetryCodes = null;
575+
if (overrides.retry_params) {
576+
overridesRetryCodes = overrides.retry_codes.retry_codes_def;
577+
}
572578
retry = mergeRetryOptions(
573579
retry,
574-
constructRetry(overridingMethod, overrides.retry_codes,
580+
constructRetry(overridingMethod, overridesRetryCodes,
575581
overrides.retry_params, retryNames));
576582
}
577583

packages/packages/google-gax/test/gax.js

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -48,8 +48,10 @@ var A_CONFIG = {
4848

4949
A_CONFIG.interfaces[SERVICE_NAME] = {
5050
'retry_codes': {
51-
'foo_retry': ['code_a', 'code_b'],
52-
'bar_retry': ['code_c']
51+
'retry_codes_def': {
52+
'foo_retry': ['code_a', 'code_b'],
53+
'bar_retry': ['code_c']
54+
}
5355
},
5456
'retry_params': {
5557
'default': {
@@ -147,8 +149,10 @@ describe('gax construct settings', function() {
147149
var overrides = {'interfaces': {}};
148150
overrides.interfaces[SERVICE_NAME] = {
149151
'retry_codes': {
150-
'bar_retry': [],
151-
'baz_retry': ['code_a']
152+
'retry_codes_def': {
153+
'bar_retry': [],
154+
'baz_retry': ['code_a']
155+
}
152156
},
153157
'retry_params': {
154158
'default': {

0 commit comments

Comments
 (0)