Resolved suggestions

This commit is contained in:
Abby Gourlay 2020-03-18 01:18:19 +00:00
parent 5c93a06e9b
commit 1df9f15859
1 changed files with 7 additions and 9 deletions

View File

@ -5,6 +5,7 @@ from __future__ import division, absolute_import, print_function, unicode_litera
import logging
import threading
import concurrent.futures
from six.moves import range, queue as Queue, zip
@ -273,7 +274,6 @@ def _get_items(query, server_id=None):
# complete all tasks before allowing any results to be processed. ThreadPoolExecutor
# allows for completed tasks to be processed while other tasks are completed on other
# threads. Dont be a dummy.Pool, be a ThreadPoolExecutor
import concurrent.futures
p = concurrent.futures.ThreadPoolExecutor(DTHREADS)
results = p.map(lambda params: _get(url, params, server_id=server_id), query_params)
@ -284,14 +284,12 @@ def _get_items(query, server_id=None):
result = result or {'Items': []}
# Mitigates #216 till the server validates the date provided is valid
for count in range(0, len(result["Items"])):
if result["Items"][count].get('ProductionYear'):
try:
from datetime import date
date(result["Items"][count]["ProductionYear"], 1, 1)
except ValueError:
LOG.info("#216 mitigation triggered. Setting ProductionYear to None")
result["Items"][count]["ProductionYear"] = None
if result['Items'][0].get('ProductionYear'):
try:
date(result['Items'][0]['ProductionYear'], 1, 1)
except ValueError:
LOG.info('#216 mitigation triggered. Setting ProductionYear to None')
result['Items'][0]['ProductionYear'] = None
items['Items'].extend(result['Items'])
# Using items to return data and communicate a restore point back to the callee is