|
14 | 14 |
|
15 | 15 | #include "google/cloud/bigtable/client.h" |
16 | 16 | #include "google/cloud/bigtable/internal/defaults.h" |
| 17 | +#include "google/cloud/bigtable/retry_policy.h" |
17 | 18 | #include "google/cloud/bigtable/testing/table_integration_test.h" |
18 | 19 | #include "google/cloud/log.h" |
19 | 20 | #include "google/cloud/testing_util/chrono_literals.h" |
@@ -694,15 +695,19 @@ TEST_P(DataIntegrationTest, ClientQueryTest) { |
694 | 695 | }; |
695 | 696 | BulkApply(table, created); |
696 | 697 | auto data_connection = table.connection(); |
697 | | - auto client = |
698 | | - Client(data_connection, |
699 | | - Options{} |
700 | | - .set<DataRetryPolicyOption>( |
701 | | - DataLimitedErrorCountRetryPolicy(0).clone()) |
702 | | - .set<DataBackoffPolicyOption>( |
703 | | - google::cloud::internal::ExponentialBackoffPolicy( |
704 | | - ms(0), ms(0), 2.0) |
705 | | - .clone())); |
| 698 | + auto client = Client( |
| 699 | + data_connection, |
| 700 | + Options{} |
| 701 | + .set<DataRetryPolicyOption>( |
| 702 | + DataLimitedErrorCountRetryPolicy(0).clone()) |
| 703 | + .set<DataBackoffPolicyOption>( |
| 704 | + google::cloud::internal::ExponentialBackoffPolicy(ms(0), ms(0), |
| 705 | + 2.0) |
| 706 | + .clone()) |
| 707 | + .set<bigtable::experimental::QueryPlanRefreshRetryPolicyOption>( |
| 708 | + bigtable::experimental:: |
| 709 | + QueryPlanRefreshLimitedErrorCountRetryPolicy(0) |
| 710 | + .clone())); |
706 | 711 | std::vector<std::string> full_table_path = |
707 | 712 | absl::StrSplit(table.table_name(), '/'); |
708 | 713 | auto table_name = full_table_path.back(); |
|
0 commit comments