Skip to content

Commit

Permalink
test(storage): deflake decompressive transcoding test (#14549)
Browse files Browse the repository at this point in the history
Use timeouts more appropriate for gRPC, specially after the gRPC timeout
scaling fixes.
  • Loading branch information
coryan authored Jul 24, 2024
1 parent 9149a06 commit c8a8f83
Showing 1 changed file with 3 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -64,10 +64,7 @@ auto constexpr kFirstLine =
TEST_F(DecompressiveTranscodingIntegrationTest, WriteAndReadJson) {
if (UsingGrpc()) GTEST_SKIP();

auto client = MakeIntegrationTestClient(
Options{}
.set<TransferStallTimeoutOption>(std::chrono::seconds(3))
.set<RetryPolicyOption>(LimitedErrorCountRetryPolicy(5).clone()));
auto client = MakeIntegrationTestClient();

auto object_name = MakeRandomObjectName();
auto insert = client.InsertObject(
Expand All @@ -93,10 +90,7 @@ TEST_F(DecompressiveTranscodingIntegrationTest, WriteAndReadJson) {
}

TEST_F(DecompressiveTranscodingIntegrationTest, WriteAndReadCompressedJson) {
auto client = MakeIntegrationTestClient(
Options{}
.set<TransferStallTimeoutOption>(std::chrono::seconds(3))
.set<RetryPolicyOption>(LimitedErrorCountRetryPolicy(5).clone()));
auto client = MakeIntegrationTestClient();

auto object_name = MakeRandomObjectName();
auto insert = client.InsertObject(
Expand Down Expand Up @@ -127,9 +121,7 @@ TEST_F(DecompressiveTranscodingIntegrationTest, ResumeGunzippedDownloadJson) {
auto client = MakeIntegrationTestClient(
Options{}
.set<MaximumCurlSocketRecvSizeOption>(16 * 1024)
.set<DownloadBufferSizeOption>(1024)
.set<TransferStallTimeoutOption>(std::chrono::seconds(3))
.set<RetryPolicyOption>(LimitedErrorCountRetryPolicy(5).clone()));
.set<DownloadBufferSizeOption>(1024));

auto object_name = MakeRandomObjectName();
auto insert = client.InsertObject(
Expand Down

0 comments on commit c8a8f83

Please sign in to comment.