drincruz
diff --git a/‎bigquery/api/streaming.py
Copy file name to clipboardExpand all lines: bigquery/api/streaming.py
+6-4Lines changed: 6 additions & 4 deletions b/‎bigquery/api/streaming.py
Copy file name to clipboardExpand all lines: bigquery/api/streaming.py
+6-4Lines changed: 6 additions & 4 deletions
@@ -35,11 +35,13 @@
 # [START stream_row_to_bigquery]
 def stream_row_to_bigquery(bigquery, project_id, dataset_id, table_name, row,
                            num_retries=5):
-    # Generate a unique row id so retries
-    # don't accidentally duplicate insert
     insert_all_data = {
-        'insertId': str(uuid.uuid4()),
-        'rows': [{'json': row}]
+        'rows': [{
+            'json': row,
+            # Generate a unique id for each row so retries don't accidentally
+            # duplicate insert
+            'insertId': str(uuid.uuid4()),
+        }]
     }
     return bigquery.tabledata().insertAll(
         projectId=project_id,