fixing for test

Author: aysim319

_delphi_utils_python/delphi_utils/__init__.py

@@ -4,15 +4,15 @@
 from __future__ import absolute_import
 
 from .archive import ArchiveDiffer, GitArchiveDiffer, S3ArchiveDiffer
+from .covidcast_wrapper import metadata, signal
 from .export import create_export_csv
-from .utils import read_params
-
-from .slack_notifier import SlackNotifier
-from .logger import get_structured_logger
 from .geomap import GeoMapper
-from .smooth import Smoother
-from .signal import add_prefix
+from .logger import get_structured_logger
 from .nancodes import Nans
+from .signal import add_prefix
+from .slack_notifier import SlackNotifier
+from .smooth import Smoother
+from .utils import read_params
 from .weekday import Weekday
 
 __version__ = "0.3.24"

_delphi_utils_python/delphi_utils/validator/datafetcher.py

@@ -3,14 +3,15 @@
 
 import re
 import threading
+import warnings
 from os import listdir
 from os.path import isfile, join
-import warnings
-import requests
-import pandas as pd
+
 import numpy as np
+import pandas as pd
+import requests
+from delphi_utils import covidcast_wrapper
 
-from ..covidcast_wrapper import metadata, signal
 from .errors import APIDataFetchError, ValidationFailure
 
 FILENAME_REGEX = re.compile(
@@ -117,7 +118,7 @@ def get_geo_signal_combos(data_source, api_key):
     source_signal_mappings = {i['source']:i['db_source'] for i in
         meta_response.json()}
 
-    meta = metadata()
+    meta = covidcast_wrapper.metadata()
 
     source_meta = meta[meta['data_source'] == data_source]
     # Need to convert np.records to tuples so they are hashable and can be used in sets and dicts.
@@ -162,7 +163,7 @@ def fetch_api_reference(data_source, start_date, end_date, geo_type, signal_type
     Formatting is changed to match that of source data CSVs.
     """
     with warnings.catch_warnings():
-        api_df = signal(data_source, signal_type, start_date, end_date, geo_type)
+        api_df = covidcast_wrapper.signal(data_source, signal_type, start_date, end_date, geo_type)
 
 
     error_context = f"when fetching reference data from {start_date} to {end_date} " +\

_delphi_utils_python/tests/test_covidcast_wrapper.py

@@ -4,17 +4,12 @@
 from delphi_utils import covidcast_wrapper
 import covidcast
 from freezegun import freeze_time
-import os
 from pandas.testing import assert_frame_equal
 
 TEST_DIR = Path(__file__).parent
-API_KEY = os.environ.get('DELPHI_API_KEY')
-covidcast.use_api_key(API_KEY)
 class TestCovidcastWrapper:
-    API_KEY = os.environ.get('DELPHI_API_KEY')
-    covidcast.use_api_key(API_KEY)
     def test_metadata(self):
-        expected_df = pd.read_pickle(f"{TEST_DIR}/test_data/covidcast_metadata.pkl")
+        expected_df = covidcast.metadata()
         df = covidcast_wrapper.metadata()
         assert_frame_equal(expected_df, df)
 

_delphi_utils_python/tests/test_data/covidcast_metadata.pkl

@@ -57,7 +57,7 @@ def test_bad_api_key(self, **kwargs):
             get_geo_signal_combos("chng", api_key="")
 
     @mock.patch('requests.get', side_effect=mocked_requests_get)
-    @mock.patch("covidcast.metadata")
+    @mock.patch("delphi_utils.covidcast_wrapper.metadata")
     def test_get_geo_signal_combos(self, mock_metadata, mock_get):
         """Test that the geo signal combos are correctly pulled from the covidcast metadata."""
         # Need to use actual data_source and signal names since we reference the API
@@ -87,7 +87,7 @@ def test_get_geo_signal_combos(self, mock_metadata, mock_get):
              ("msa", "pcr_specimen_positivity_rate"),
              ("msa", "pcr_specimen_total_tests")])
 
-    @mock.patch("covidcast.signal")
+    @mock.patch("delphi_utils.covidcast_wrapper.signal")
     def test_threaded_api_calls(self, mock_signal):
         """Test that calls to the covidcast API are made."""