Skip to content

Commit 5976b97

Browse files
committed
fix toher s3 suites that use s3 table function
1 parent d660469 commit 5976b97

File tree

3 files changed

+21
-0
lines changed

3 files changed

+21
-0
lines changed

s3/tests/disk.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2533,6 +2533,13 @@ def disk_tests(self, uri, bucket_prefix):
25332533
self.context.uri = None
25342534
self.context.bucket_path = None
25352535

2536+
with Given("I add S3 credentials configuration"):
2537+
named_s3_credentials(
2538+
access_key_id=self.context.access_key_id,
2539+
secret_access_key=self.context.secret_access_key,
2540+
restart=True,
2541+
)
2542+
25362543
for scenario in loads(current_module(), Scenario):
25372544
with allow_s3_truncate(self.context.node):
25382545
scenario()

s3/tests/hive_partitioning.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -226,6 +226,13 @@ def minio(self, uri, bucket_prefix):
226226
self.context.uri = f"{uri}table_function/{temp_s3_path}/"
227227
self.context.bucket_path = f"{bucket_prefix}/table_function/{temp_s3_path}"
228228

229+
with Given("I add S3 credentials configuration"):
230+
named_s3_credentials(
231+
access_key_id=self.context.access_key_id,
232+
secret_access_key=self.context.secret_access_key,
233+
restart=True,
234+
)
235+
229236
with allow_s3_truncate(self.context.node):
230237

231238
cluster_names = {None}.union(self.context.clusters)

s3/tests/remote_s3_function.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -110,6 +110,13 @@ def minio(self, uri, bucket_prefix):
110110
self.context.uri = f"{uri}table_function/{temp_s3_path}/"
111111
self.context.bucket_path = f"{bucket_prefix}/table_function/{temp_s3_path}"
112112

113+
with Given("I add S3 credentials configuration"):
114+
named_s3_credentials(
115+
access_key_id=self.context.access_key_id,
116+
secret_access_key=self.context.secret_access_key,
117+
restart=True,
118+
)
119+
113120
with allow_s3_truncate(self.context.node):
114121
cluster_names = {None}.union(self.context.clusters)
115122
debug(cluster_names)

0 commit comments

Comments
 (0)