File tree 1 file changed +4
-2
lines changed
1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -796,12 +796,14 @@ def test_load_batch(
796
796
printer ("checking the jobs' responses" )
797
797
for job_spec in job_specs :
798
798
job_id : str = job_spec ["job_id" ]
799
- job_status = requests .get (f"{ api_endpoint } ?jobID={ job_id } " ).json ()["job_status" ]
799
+ job = requests .get (f"{ api_endpoint } ?jobID={ job_id } " ).json ()
800
+ job_status = job ["job_status" ]
801
+ job_metrics = job ["metrics" ]
800
802
801
803
assert (
802
804
job_status ["batches_in_queue" ] == 0
803
805
), f"there are still batches in queue ({ job_status ['batches_in_queue' ]} ) for job ID { job_id } "
804
- assert job_spec [ "metrics" ] ["succeeded" ] == math .ceil (items_per_job / batch_size )
806
+ assert job_metrics ["succeeded" ] == math .ceil (items_per_job / batch_size )
805
807
806
808
num_objects = 0
807
809
for page in paginator .paginate (Bucket = bucket , Prefix = os .path .join (key , job_id )):
You can’t perform that action at this time.
0 commit comments