Skip to content

Commit cdb2c8a

Browse files
committed
Generate second presigned uri for testing expiration
1 parent ff3deac commit cdb2c8a

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

lib/trino-filesystem/src/test/java/io/trino/filesystem/AbstractTestTrinoFileSystem.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1047,7 +1047,10 @@ public void testPreSignedUris()
10471047
}
10481048

10491049
Optional<UriLocation> directLocation = getFileSystem()
1050-
.preSignedUri(location, new Duration(3, SECONDS));
1050+
.preSignedUri(location, new Duration(30, SECONDS));
1051+
1052+
Optional<UriLocation> expiredDirectLocation = getFileSystem()
1053+
.preSignedUri(location, new Duration(1, SECONDS));
10511054

10521055
assertThat(directLocation).isPresent();
10531056
assertThat(retrieveUri(directLocation.get()))
@@ -1058,8 +1061,9 @@ public void testPreSignedUris()
10581061
.isEqualTo(TEST_BLOB_CONTENT_PREFIX + location);
10591062

10601063
// Check if after a timeout the pre-signed URI is no longer valid
1061-
assertEventually(new Duration(5, SECONDS), new Duration(1, SECONDS), () -> assertThatThrownBy(() -> retrieveUri(directLocation.get()))
1062-
.isInstanceOf(IOException.class));
1064+
assertEventually(new Duration(5, SECONDS), new Duration(1, SECONDS), () -> assertThatThrownBy(() -> retrieveUri(expiredDirectLocation.get()))
1065+
.isInstanceOf(IOException.class)
1066+
.hasMessageContaining("Failed to retrieve"));
10631067
}
10641068
}
10651069

0 commit comments

Comments
 (0)