[BigQuery] Additional error check (#1091)

artie-labs · Dec 18, 2024 · 6c966cb · 6c966cb
1 parent 1d285eb
commit 6c966cb
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/clients/bigquery/bigquery.go b/clients/bigquery/bigquery.go
@@ -183,8 +183,13 @@ func (s *Store) putTable(ctx context.Context, bqTableID dialect.TableIdentifier,
 			return fmt.Errorf("failed to append rows: %w", err)
 		}
 
-		if resp, err := result.FullResponse(ctx); err != nil {
-			return fmt.Errorf("failed to get response (%s): %w", resp.GetError().String(), err)
+		resp, err := result.FullResponse(ctx)
+		if err != nil {
+			return fmt.Errorf("failed to get response: %w", err)
+		}
+
+		if status := resp.GetError(); status != nil {
+			return fmt.Errorf("failed to append rows: %s", status.String())
 		}
 
 		return nil