File tree Expand file tree Collapse file tree 2 files changed +12
-3
lines changed Expand file tree Collapse file tree 2 files changed +12
-3
lines changed Original file line number Diff line number Diff line change 75
75
76
76
- Corrected parameter checking in ``MastMissions `` to ensure case-sensitive comparisons. [#3260]
77
77
78
+ - Add batching to ``MastMissions.get_product_list `` to avoid server errors and allow for a larger number of input datasets. [#3230]
79
+
80
+
78
81
simbad
79
82
^^^^^^
80
83
Original file line number Diff line number Diff line change @@ -392,12 +392,18 @@ def get_product_list_async(self, datasets):
392
392
dataset_chunks = list (utils .split_list_into_chunks (datasets , max_batch ))
393
393
394
394
results = [] # list to store responses from each batch
395
- with ProgressBarOrSpinner (len ( dataset_chunks ) , f'Fetching products for { num_datasets } unique datasets '
395
+ with ProgressBarOrSpinner (num_datasets , f'Fetching products for { num_datasets } unique datasets '
396
396
f'in { len (dataset_chunks )} batches ...' ) as pb :
397
- for i , chunk in enumerate (dataset_chunks ):
398
- pb .update (i )
397
+ datasets_fetched = 0
398
+ pb .update (0 )
399
+ for chunk in dataset_chunks :
400
+ # Send request for each chunk and add response to list
399
401
params = {'dataset_ids' : chunk }
400
402
results .append (self ._service_api_connection .missions_request_async (self .service , params ))
403
+
404
+ # Update progress bar with the number of datasets that have had products fetched
405
+ datasets_fetched += len (chunk )
406
+ pb .update (datasets_fetched )
401
407
return results
402
408
else :
403
409
# Single batch request
You can’t perform that action at this time.
0 commit comments