Skip to content

Commit 724e21b

Browse files
committed
Fixed isCDC method with proper PostgresUtil function and corresponding imports
1 parent 6a538bb commit 724e21b

File tree

1 file changed

+4
-2
lines changed
  • airbyte-integrations/connectors/source-postgres/src/test/java/io/airbyte/integrations/source/postgres

1 file changed

+4
-2
lines changed

airbyte-integrations/connectors/source-postgres/src/test/java/io/airbyte/integrations/source/postgres/PostgresSourceTest.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,11 @@
88
import static io.airbyte.integrations.source.postgres.utils.PostgresUnitTestsUtil.map;
99
import static io.airbyte.integrations.source.postgres.utils.PostgresUnitTestsUtil.setEmittedAtToNull;
1010
import static org.junit.jupiter.api.Assertions.assertEquals;
11+
import static org.junit.jupiter.api.Assertions.assertFalse;
1112
import static org.junit.jupiter.api.Assertions.assertTrue;
1213

1314
import com.fasterxml.jackson.databind.JsonNode;
15+
import com.fasterxml.jackson.databind.node.ObjectNode;
1416
import com.google.common.collect.ImmutableMap;
1517
import com.google.common.collect.Lists;
1618
import com.google.common.collect.Sets;
@@ -458,12 +460,12 @@ void testReadSuccess() throws Exception {
458460
void testIsCdc() {
459461
final JsonNode config = getConfig(PSQL_DB, dbName);
460462

461-
assertFalse(PostgresSource.isCdc(config));
463+
assertFalse(PostgresUtils.isCdc(config));
462464

463465
((ObjectNode) config).set("replication_method", Jsons.jsonNode(ImmutableMap.of(
464466
"replication_slot", "slot",
465467
"publication", "ab_pub")));
466-
assertTrue(PostgresSource.isCdc(config));
468+
assertTrue(PostgresUtils.isCdc(config));
467469
}
468470

469471
@Test

0 commit comments

Comments
 (0)