From 008f5025f7a3672e638ff5531377baa32f342504 Mon Sep 17 00:00:00 2001 From: galsalomon66 Date: Mon, 10 Apr 2023 12:26:59 +0300 Subject: [PATCH] progress nessage is sent back upon processing the object, the change make sure it stay with the max result Signed-off-by: galsalomon66 --- s3tests_boto3/functional/test_s3select.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/s3tests_boto3/functional/test_s3select.py b/s3tests_boto3/functional/test_s3select.py index 1a2ccaf..bda6ff7 100644 --- a/s3tests_boto3/functional/test_s3select.py +++ b/s3tests_boto3/functional/test_s3select.py @@ -297,18 +297,19 @@ def run_s3select(bucket,key,query,column_delim=",",row_delim="\n",quot_char='"', result += records else: result = [] + max_progress_scanned = 0 for event in r['Payload']: if 'Records' in event: records = event['Records'] result.append(records.copy()) if 'Progress' in event: - progress = event['Progress'] - result_status['Progress'] = event['Progress'] + if(event['Progress']['Details']['BytesScanned'] > max_progress_scanned): + max_progress_scanned = event['Progress']['Details']['BytesScanned'] + result_status['Progress'] = event['Progress'] + if 'Stats' in event: - stats = event['Stats'] result_status['Stats'] = event['Stats'] if 'End' in event: - end = event['End'] result_status['End'] = event['End'] if progress == False: