From 228765c5ea281ddadb78267f40397ae7ffcee099 Mon Sep 17 00:00:00 2001
From: Edward Gao <edward.gao@airbyte.io>
Date: Thu, 5 Sep 2024 09:29:52 -0700
Subject: [PATCH] basic smoke test

---
 .../airbyte/cdk/test/util/DestinationProcess.kt  | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/airbyte-cdk/bulk/core/load/src/testFixtures/kotlin/io/airbyte/cdk/test/util/DestinationProcess.kt b/airbyte-cdk/bulk/core/load/src/testFixtures/kotlin/io/airbyte/cdk/test/util/DestinationProcess.kt
index fdd00dce6cdd..82a17e85d037 100644
--- a/airbyte-cdk/bulk/core/load/src/testFixtures/kotlin/io/airbyte/cdk/test/util/DestinationProcess.kt
+++ b/airbyte-cdk/bulk/core/load/src/testFixtures/kotlin/io/airbyte/cdk/test/util/DestinationProcess.kt
@@ -23,18 +23,18 @@ interface DestinationProcess {
     fun waitUntilDone()
 }
 
-fun interface DestinationProcessFactory<Config> {
-    fun createDestinationProcess(
+abstract class DestinationProcessFactory<Config> {
+    abstract fun createDestinationProcess(
         command: String,
-        config: Config,
-        catalog: ConfiguredAirbyteCatalog,
+        config: Config? = null,
+        catalog: ConfiguredAirbyteCatalog? = null,
     ): DestinationProcess
 }
 
 class NonDockerizedDestination(
     command: String,
-    config: JsonNode,
-    catalog: ConfiguredAirbyteCatalog,
+    config: JsonNode?,
+    catalog: ConfiguredAirbyteCatalog?,
 ): DestinationProcess {
     init {
         // invoke whatever CDK stuff exists to run a destination connector
@@ -59,8 +59,8 @@ class NonDockerizedDestination(
 
 class DockerizedDestination(
     command: String,
-    config: JsonNode,
-    catalog: ConfiguredAirbyteCatalog,
+    config: JsonNode?,
+    catalog: ConfiguredAirbyteCatalog?,
 ): DestinationProcess {
     init {
         // launch a docker container...