Skip to content

Commit 1604845

Browse files
committed
added some test cases
1 parent e50624c commit 1604845

File tree

1 file changed

+15
-7
lines changed

1 file changed

+15
-7
lines changed

integrations/acquisition/covidcast/test_coverage_crossref_update.py

Lines changed: 15 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
import delphi.operations.secrets as secrets
1515
import delphi.epidata.acquisition.covidcast.database as live
1616
from delphi.epidata.maintenance.coverage_crossref_updater import main
17-
from delphi.epidata.acquisition.covidcast.test_utils import CovidcastBase
17+
from delphi.epidata.acquisition.covidcast.test_utils import CovidcastBase, CovidcastTestRow
1818

1919
# use the local instance of the Epidata API
2020
BASE_URL = 'http://delphi_web_epidata/epidata' # NOSONAR
@@ -28,9 +28,7 @@ def localSetUp(self):
2828
self._db._cursor.execute('TRUNCATE TABLE `coverage_crossref`')
2929

3030
@staticmethod
31-
def _make_request(params=None):
32-
if params is None:
33-
params = {'geo': 'state:*'}
31+
def _make_request(params):
3432
response = requests.get(f"{Epidata.BASE_URL}/covidcast/geo_coverage", params=params, auth=Epidata.auth)
3533
response.raise_for_status()
3634
return response.json()
@@ -45,7 +43,7 @@ def test_caching(self):
4543
CovidcastTestRow.make_default_row(geo_type="state", geo_value="ny", signal="sig2"),
4644
])
4745

48-
results = self._make_request()
46+
results = self._make_request(params = {'geo': 'state:*'})
4947

5048
# make sure the tables are empty
5149
self.assertEqual(results, {
@@ -57,12 +55,12 @@ def test_caching(self):
5755
# update the coverage crossref table
5856
main()
5957

60-
results = self._make_request()
58+
results = self._make_request(params = {'geo': 'state:*'})
6159

6260
# make sure the data was actually served
6361
self.assertEqual(results, {
6462
'result': 1,
65-
'epidata': [{'signal': 'sig', 'source': 'src'}],
63+
'epidata': [{'signal': 'sig', 'source': 'src'}, {'signal': 'sig2', 'source': 'src'}],
6664
'message': 'success',
6765
})
6866

@@ -83,3 +81,13 @@ def test_caching(self):
8381
'epidata': [{'signal': 'sig', 'source': 'src'}],
8482
'message': 'success',
8583
})
84+
85+
results = self._make_request(params = {'geo': 'state:ny'})
86+
87+
# make sure the data was actually served
88+
self.assertEqual(results, {
89+
'result': 1,
90+
'epidata': [{'signal': 'sig', 'source': 'src'}, {'signal': 'sig2', 'source': 'src'}],
91+
'message': 'success',
92+
})
93+

0 commit comments

Comments
 (0)