Skip to content

Commit 2fe6edf

Browse files
committed
[aws] Debugging for regression runs
1 parent a569837 commit 2fe6edf

2 files changed

Lines changed: 6 additions & 0 deletions

File tree

benchmarks/300.utilities/311.compression/input.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,4 +36,5 @@ def generate_input(data_dir, size, benchmarks_bucket, input_paths, output_paths,
3636
input_config['bucket']['bucket'] = benchmarks_bucket
3737
input_config['bucket']['input'] = input_paths[0]
3838
input_config['bucket']['output'] = output_paths[0]
39+
print(input_config)
3940
return input_config

benchmarks/wrappers/aws/python/storage.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,12 @@ def download(self, bucket, file, filepath):
3131
self.client.download_file(bucket, file, filepath)
3232

3333
def download_directory(self, bucket, prefix, path):
34+
print(f"DEBUG: bucket={bucket}, prefix={prefix}")
3435
objects = self.client.list_objects_v2(Bucket=bucket, Prefix=prefix)
36+
print(f"DEBUG: got {objects.get('KeyCount', 0)} keys, response keys: {list(objects.keys())}")
37+
# 'Contents' key is only present when objects are found
38+
if 'Contents' not in objects:
39+
raise RuntimeError(f"No objects found in bucket '{bucket}' with prefix '{prefix}'")
3540
for obj in objects['Contents']:
3641
file_name = obj['Key']
3742
path_to_file = os.path.dirname(file_name)

0 commit comments

Comments
 (0)