updated to new key for update timestamp

Author: aysim319

nhsn/delphi_nhsn/pull.py

@@ -38,7 +38,7 @@ def check_last_updated(socrata_token, dataset_id, logger):
         client = Socrata("data.cdc.gov", socrata_token)
         response = client.get_metadata(dataset_id)
 
-        updated_timestamp = datetime.utcfromtimestamp(int(response["rowsUpdatedAt"]))
+        updated_timestamp = datetime.utcfromtimestamp(int(response["viewLastModified"]))
         now = datetime.utcnow()
         recently_updated_source = (now - updated_timestamp) < timedelta(days=1)
 

nhsn/tests/test_pull.py

@@ -123,7 +123,7 @@ def test_pull_nhsn_data_backup(self, mock_socrata, dataset, caplog, params):
         mock_socrata.return_value = mock_client
         mock_client.get.side_effect = [dataset["test_data"], []]
 
-        mock_client.get_metadata.return_value = {"rowsUpdatedAt": now}
+        mock_client.get_metadata.return_value = {"viewLastModified": now}
 
         today = pd.Timestamp.today().strftime("%Y%m%d")
         backup_dir = params["common"]["backup_dir"]
@@ -163,7 +163,7 @@ def test_pull_nhsn_data_backup(self, mock_socrata, dataset, caplog, params):
     def test_check_last_updated(self, mock_socrata, dataset, updatedAt, caplog):
         mock_client = MagicMock()
         mock_socrata.return_value = mock_client
-        mock_client.get_metadata.return_value = {"rowsUpdatedAt": updatedAt }
+        mock_client.get_metadata.return_value = {"viewLastModified": updatedAt }
         logger = get_structured_logger()
 
         check_last_updated(mock_client, dataset["id"], logger)