def test_stream_row_to_bigquery(self):
    with open(os.path.join(self.resource_path, 'streamrows.json'), 'r') as rows_file:
        rows = json.load(rows_file)
    for result in run(self.constants['projectId'], self.constants['datasetId'], self.constants['newTableId'], rows, 5):
        self.assertIsNotNone(json.loads(result))
def test_stream_row_to_bigquery(self):
    with open(os.path.join(self.resource_path, 'streamrows.json'), 'r') as rows_file:
        rows = json.load(rows_file)
    for result in run(self.constants['projectId'], self.constants['datasetId'], self.constants['newTableId'], rows, 5):
        self.assertIsNotNone(json.loads(result))