@@ -40,6 +40,7 @@ def _fetch(self, endpoint="/", is_compatibility=False, **params):
40
40
if is_compatibility :
41
41
url = BASE_URL_OLD
42
42
# only set endpoint if it's not already set
43
+ # only set endpoint if it's not already set
43
44
params .setdefault ("endpoint" , "covidcast" )
44
45
if params .get ("source" ):
45
46
params .setdefault ("data_source" , params .get ("source" ))
@@ -77,7 +78,7 @@ def test_basic(self):
77
78
78
79
def test_compatibility (self ):
79
80
"""Request at the /api.php endpoint."""
80
- rows = [CovidcastRow .make_default_row (source = "src" , signal = "sig" , time_value = 20200401 + i , value = i ) for i in range (10 )]
81
+ rows = [CovidcastRow .make_default_row (source = "src" , signal = "sig" , time_value = 2020_04_01 + i , value = i ) for i in range (10 )]
81
82
first = rows [0 ]
82
83
self ._insert_rows (rows )
83
84
@@ -93,7 +94,7 @@ def test_trend(self):
93
94
"""Request a signal from the /trend endpoint."""
94
95
95
96
num_rows = 30
96
- rows = [CovidcastRow .make_default_row (time_value = 20200401 + i , value = i ) for i in range (num_rows )]
97
+ rows = [CovidcastRow .make_default_row (time_value = 2020_04_01 + i , value = i ) for i in range (num_rows )]
97
98
first = rows [0 ]
98
99
last = rows [- 1 ]
99
100
ref = rows [num_rows // 2 ]
@@ -129,7 +130,7 @@ def test_trendseries(self):
129
130
"""Request a signal from the /trendseries endpoint."""
130
131
131
132
num_rows = 3
132
- rows = [CovidcastRow .make_default_row (time_value = 20200401 + i , value = num_rows - i ) for i in range (num_rows )]
133
+ rows = [CovidcastRow .make_default_row (time_value = 2020_04_01 + i , value = num_rows - i ) for i in range (num_rows )]
133
134
first = rows [0 ]
134
135
last = rows [- 1 ]
135
136
self ._insert_rows (rows )
@@ -221,7 +222,7 @@ def test_correlation(self):
221
222
def test_csv (self ):
222
223
"""Request a signal from the /csv endpoint."""
223
224
224
- rows = [CovidcastRow .make_default_row (time_value = 20200401 + i , value = i ) for i in range (10 )]
225
+ rows = [CovidcastRow .make_default_row (time_value = 2020_04_01 + i , value = i ) for i in range (10 )]
225
226
first = rows [0 ]
226
227
self ._insert_rows (rows )
227
228
@@ -262,7 +263,7 @@ def test_meta(self):
262
263
"""Request a signal from the /meta endpoint."""
263
264
264
265
num_rows = 10
265
- rows = [CovidcastRow .make_default_row (time_value = 20200401 + i , value = i , source = "fb-survey" , signal = "smoothed_cli" ) for i in range (num_rows )]
266
+ rows = [CovidcastRow .make_default_row (time_value = 2020_04_01 + i , value = i , source = "fb-survey" , signal = "smoothed_cli" ) for i in range (num_rows )]
266
267
self ._insert_rows (rows )
267
268
first = rows [0 ]
268
269
last = rows [- 1 ]
@@ -302,7 +303,7 @@ def test_coverage(self):
302
303
"""Request a signal from the /coverage endpoint."""
303
304
304
305
num_geos_per_date = [10 , 20 , 30 , 40 , 44 ]
305
- dates = [20200401 + i for i in range (len (num_geos_per_date ))]
306
+ dates = [2020_04_01 + i for i in range (len (num_geos_per_date ))]
306
307
rows = [CovidcastRow .make_default_row (time_value = dates [i ], value = i , geo_value = str (geo_value )) for i , num_geo in enumerate (num_geos_per_date ) for geo_value in range (num_geo )]
307
308
self ._insert_rows (rows )
308
309
first = rows [0 ]
0 commit comments