Skip to content

Commit 413f087

Browse files
committed
chore: Pass the executor in
1 parent c0e6adc commit 413f087

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

java-bigquery/google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/BigQueryRetryHelper.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,7 @@ private static <V> V run(
128128
bigQueryRetryConfig); // using BigQueryRetryAlgorithm in place of
129129
// com.google.api.gax.retrying.RetryAlgorithm, as
130130
// BigQueryRetryAlgorithm retries considering bigQueryRetryConfig
131-
RetryingExecutor<V> executor = new DirectRetryingExecutor<>(retryAlgorithm);
131+
DirectRetryingExecutor<V> executor = new DirectRetryingExecutor<>(retryAlgorithm);
132132

133133
// 1. Resolve method name for the tracer span
134134
String methodName = "execute";
@@ -175,7 +175,7 @@ public Set<StatusCode.Code> getRetryableCodes() {
175175
});
176176
}
177177

178-
RetryingFuture<V> retryingFuture = executor.createFuture(callable);
178+
RetryingFuture<V> retryingFuture = executor.createFuture(callable, context);
179179
executor.submit(retryingFuture);
180180
return retryingFuture.get();
181181
}

0 commit comments

Comments
 (0)