|
23 | 23 | import com.google.api.gax.retrying.RetryAlgorithm; |
24 | 24 | import com.google.api.gax.retrying.RetrySettings; |
25 | 25 | import com.google.api.gax.retrying.RetryingContext; |
26 | | -import com.google.api.gax.retrying.RetryingExecutor; |
27 | 26 | import com.google.api.gax.retrying.RetryingFuture; |
28 | 27 | import com.google.api.gax.retrying.TimedAttemptSettings; |
29 | 28 | import com.google.api.gax.retrying.TimedRetryAlgorithm; |
@@ -63,7 +62,15 @@ public static <V> V runWithRetries( |
63 | 62 | BigQueryRetryConfig bigQueryRetryConfig, |
64 | 63 | boolean isOpenTelemetryEnabled, |
65 | 64 | Tracer openTelemetryTracer) { |
66 | | - return runWithRetries(callable, retrySettings, resultRetryAlgorithm, clock, bigQueryRetryConfig, isOpenTelemetryEnabled, openTelemetryTracer, null); |
| 65 | + return runWithRetries( |
| 66 | + callable, |
| 67 | + retrySettings, |
| 68 | + resultRetryAlgorithm, |
| 69 | + clock, |
| 70 | + bigQueryRetryConfig, |
| 71 | + isOpenTelemetryEnabled, |
| 72 | + openTelemetryTracer, |
| 73 | + null); |
67 | 74 | } |
68 | 75 |
|
69 | 76 | public static <V> V runWithRetries( |
@@ -141,28 +148,30 @@ private static <V> V run( |
141 | 148 | } |
142 | 149 |
|
143 | 150 | // 2. Obtain ApiTracer from the factory |
144 | | - final ApiTracer tracer = (apiTracerFactory != null) |
145 | | - ? apiTracerFactory.newTracer( |
146 | | - null, SpanName.of("BigQuery", methodName), ApiTracerFactory.OperationType.Unary) |
147 | | - : BaseApiTracer.getInstance(); |
| 151 | + final ApiTracer tracer = |
| 152 | + (apiTracerFactory != null) |
| 153 | + ? apiTracerFactory.newTracer( |
| 154 | + null, SpanName.of("BigQuery", methodName), ApiTracerFactory.OperationType.Unary) |
| 155 | + : BaseApiTracer.getInstance(); |
148 | 156 |
|
149 | 157 | // 3. Construct RetryingContext |
150 | | - RetryingContext context = new RetryingContext() { |
151 | | - @Override |
152 | | - public ApiTracer getTracer() { |
153 | | - return tracer; |
154 | | - } |
| 158 | + RetryingContext context = |
| 159 | + new RetryingContext() { |
| 160 | + @Override |
| 161 | + public ApiTracer getTracer() { |
| 162 | + return tracer; |
| 163 | + } |
155 | 164 |
|
156 | | - @Override |
157 | | - public RetrySettings getRetrySettings() { |
158 | | - return retrySettings; |
159 | | - } |
| 165 | + @Override |
| 166 | + public RetrySettings getRetrySettings() { |
| 167 | + return retrySettings; |
| 168 | + } |
160 | 169 |
|
161 | | - @Override |
162 | | - public Set<StatusCode.Code> getRetryableCodes() { |
163 | | - return Collections.emptySet(); |
164 | | - } |
165 | | - }; |
| 170 | + @Override |
| 171 | + public Set<StatusCode.Code> getRetryableCodes() { |
| 172 | + return Collections.emptySet(); |
| 173 | + } |
| 174 | + }; |
166 | 175 |
|
167 | 176 | // Log retry info |
168 | 177 | if (LOG.isLoggable(Level.FINEST)) { |
|
0 commit comments