dkirillov/s3-tests
1
0
Fork 0
forked from TrueCloudLab/s3-tests
Code Pull requests Activity

progress nessage is sent back upon processing the object, the change make sure it stay with the max result

Browse source 
Signed-off-by: galsalomon66 <gal.salomon@gmail.com>
This commit is contained in:
galsalomon66 2023-04-10 12:26:59 +03:00
parent bc2a3b0b70
commit 008f5025f7
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
s3tests_boto3/functional/test_s3select.py
View file

@ -297,18 +297,19 @@ def run_s3select(bucket,key,query,column_delim=",",row_delim="\n",quot_char='"',
result += records result += records
else: else:
result = [] result = []
max_progress_scanned = 0
for event in r['Payload']: for event in r['Payload']:
if 'Records' in event: if 'Records' in event:
records = event['Records'] records = event['Records']
result.append(records.copy()) result.append(records.copy())
if 'Progress' in event: if 'Progress' in event:
progress = event['Progress'] if(event['Progress']['Details']['BytesScanned'] > max_progress_scanned):
max_progress_scanned = event['Progress']['Details']['BytesScanned']
result_status['Progress'] = event['Progress'] result_status['Progress'] = event['Progress']
if 'Stats' in event: if 'Stats' in event:
stats = event['Stats']
result_status['Stats'] = event['Stats'] result_status['Stats'] = event['Stats']
if 'End' in event: if 'End' in event:
end = event['End']
result_status['End'] = event['End'] result_status['End'] = event['End']
if progress == False: if progress == False: