Merge pull request #66 from chentex/multi-request-resilience

Adds a try..except to avoid errors in mappers

backend/app/api/v1/endpoints/cpt/cptJobs.py

@@ -10,8 +10,9 @@
 router = APIRouter()
 
 products = {
-            "ocp": ocpMapper,
-           }
+    "ocp": ocpMapper,
+}
+
 
 @router.get('/api/cpt/v1/jobs',
             summary="Returns a job list from all the products.",
@@ -37,9 +38,14 @@ async def jobs(start_date: date = Query(None, description="Start date for search
         return Response(content=json.dumps({'error': "invalid date format, start_date must be less than end_date"}), status_code=422)
 
     results = pd.DataFrame()
-    for func in products.values():
-        df = await func(start_date, end_date)
-        results = pd.concat([results, df])
+    for product in products:
+        try:
+            df = await products[product](start_date, end_date)
+            results = pd.concat([results, df])
+        except ConnectionError:
+            print("Connection Error in mapper for product " + product)
+        except:
+            print("Unknown Error in mapper for product " + product)
 
     response = {
         'startDate': start_date.__str__(),