Should fix build

airbytehq · Oct 2, 2023 · d503b84 · d503b84
1 parent d2b3fff
commit d503b84
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...query/src/main/java/io/airbyte/integrations/destination/bigquery/BigQueryDestination.java b/...query/src/main/java/io/airbyte/integrations/destination/bigquery/BigQueryDestination.java
@@ -396,12 +396,12 @@ private SerializedAirbyteMessageConsumer getStandardRecordConsumer(final BigQuer
             });
           }
         },
-        () -> {
+        (hasFailed) -> {
           LOGGER.info("Started closing all connections");
           final List<Exception> exceptionsThrown = new ArrayList<>();
           writeConfigs.get().forEach((streamId, uploader) -> {
             try {
-              uploader.close(false, outputRecordCollector, null);
+              uploader.close(hasFailed, outputRecordCollector, null);
             } catch (final Exception e) {
               exceptionsThrown.add(e);
               LOGGER.error("Exception while closing uploader {}", uploader, e);