bq: fix inverted err

CHANGELOG.md

@@ -3,6 +3,12 @@ Changelog
 
 All notable changes to this project will be documented in this file.
 
+## 4.44.0 - TBD
+
+### Fixed
+
+- `gcp_bigquery` output with parquet format no longer returns errors incorrectly. (@rockwotj)
+
 ## 4.43.1 - 2024-12-09
 
 ### Fixed

internal/impl/gcp/output_bigquery.go

@@ -421,15 +421,18 @@ func (g *gcpBigQueryOutput) WriteBatch(ctx context.Context, batch service.Messag
 		}
 		for idx, job := range jobs {
 			status, err := job.Wait(ctx)
-			if err == nil {
+			if err != nil {
 				setErr(idx, fmt.Errorf("error while waiting on bigquery job: %w", err))
 				continue
 			}
 			if err = errorFromStatus(status); err != nil {
 				setErr(idx, err)
 			}
 		}
-		return batchErr
+		if batchErr != nil {
+			return batchErr
+		}
+		return nil
 	}
 
 	var data bytes.Buffer