in bigquery/main.go [360:367]
func (bq *actualBQ) WriteRow(ctx context.Context, row *bqRow) error {
ins := bq.table.Inserter()
log.V(2).Infof("Writing row: %v", row)
if err := ins.Put(ctx, row); err != nil {
return fmt.Errorf("error inserting row into BQ: %v", err)
}
return nil
}