Merge pull request #337 from sgratzl/sgratzl/streaming

streaming support

Author: krivard

integrations/acquisition/covidcast/test_csv_uploading.py

@@ -223,6 +223,7 @@ def apply_lag(expected_epidata):
     self.assertEqual(response, {
       'result': -2,
       'message': 'no results',
+      'epidata': []
     })
 
     # verify timestamps and default values are reasonable

integrations/client/test_delphi_epidata.py

@@ -239,7 +239,7 @@ def test_covidcast(self):
           'src', 'sig'*3000, 'day', 'county', 20200414, '01234')
 
       # check result
-      self.assertEqual(response_1, {'message': 'no results', 'result': -2})
+      self.assertEqual(response_1, {'message': 'no results', 'result': -2, 'epidata': []})
 
   @patch('requests.post')
   @patch('requests.get')
@@ -470,4 +470,4 @@ def test_covidcast_nowcast(self):
     response = Epidata.covidcast_nowcast(
       'src', 'sig1', 'day', 'county', 22222222, '01001')
 
-    self.assertEqual(response, {'result': -2, 'message': 'no results'})
+    self.assertEqual(response, {'result': -2, 'message': 'no results', 'epidata': []})