Skip to content

Commit 44f9db5

Browse files
committed
update to new interfac
1 parent 4a2ec81 commit 44f9db5

File tree

1 file changed

+3
-3
lines changed
  • airbyte-integrations/connectors/destination-bigquery/src/main/kotlin/io/airbyte/integrations/destination/bigquery

1 file changed

+3
-3
lines changed

airbyte-integrations/connectors/destination-bigquery/src/main/kotlin/io/airbyte/integrations/destination/bigquery/BigqueryBeansFactory.kt

+3-3
Original file line numberDiff line numberDiff line change
@@ -13,20 +13,20 @@ import io.airbyte.integrations.destination.bigquery.check.BigqueryCheckCleaner
1313
import io.micronaut.context.annotation.Factory
1414
import jakarta.inject.Named
1515
import jakarta.inject.Singleton
16-
import java.io.PipedOutputStream
16+
import java.io.InputStream
1717

1818
@Factory
1919
class BigqueryBeansFactory {
2020
@Singleton
2121
fun getChecker(
2222
catalog: DestinationCatalog,
23-
@Named("checkInputStreamPipe") pipe: PipedOutputStream,
23+
@Named("inputStream") stdinPipe: InputStream,
2424
taskLauncher: DestinationTaskLauncher,
2525
syncManager: SyncManager,
2626
) =
2727
DestinationCheckerSync(
2828
catalog,
29-
pipe,
29+
stdinPipe,
3030
WriteOperation(taskLauncher, syncManager),
3131
BigqueryCheckCleaner(),
3232
)

0 commit comments

Comments
 (0)