wrapped in try block

Author: aysim319

nhsn/delphi_nhsn/pull.py

@@ -17,18 +17,25 @@
 
 def check_last_updated(socrata_token, dataset_id, logger):
     """Check last updated timestamp to determine data should be pulled or not."""
-    client = Socrata("data.cdc.gov", socrata_token)
-    response = client.get_metadata(dataset_id)
-
-    updated_timestamp = datetime.utcfromtimestamp(int(response["rowsUpdatedAt"]))
-    now = datetime.utcnow()
-    recently_updated_source = (now - updated_timestamp) < timedelta(days=1)
-
-    prelim_prefix = "Preliminary " if dataset_id == PRELIM_DATASET_ID else ""
-    if recently_updated_source:
-        logger.info(f"{prelim_prefix}NHSN data was recently updated; Pulling data", updated_timestamp=updated_timestamp)
-    else:
-        logger.info(f"{prelim_prefix}NHSN data is stale; Skipping", updated_timestamp=updated_timestamp)
+    recently_updated_source = True
+    try:
+        client = Socrata("data.cdc.gov", socrata_token)
+        response = client.get_metadata(dataset_id)
+
+        updated_timestamp = datetime.utcfromtimestamp(int(response["rowsUpdatedAt"]))
+        now = datetime.utcnow()
+        recently_updated_source = (now - updated_timestamp) < timedelta(days=1)
+
+        prelim_prefix = "Preliminary " if dataset_id == PRELIM_DATASET_ID else ""
+        if recently_updated_source:
+            logger.info(
+                f"{prelim_prefix}NHSN data was recently updated; Pulling data", updated_timestamp=updated_timestamp
+            )
+        else:
+            logger.info(f"{prelim_prefix}NHSN data is stale; Skipping", updated_timestamp=updated_timestamp)
+    # pylint: disable=W0703
+    except Exception as e:
+        logger.info("error while processing socrata metadata; continuing processing", error=str(e))
     return recently_updated_source