update ID column to be int

airbytehq · Jul 27, 2022 · ab08875 · ab08875
1 parent 3c97cdd
commit ab08875
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/airbyte-tests/src/acceptanceTests/java/io/airbyte/test/acceptance/BasicAcceptanceTests.java b/airbyte-tests/src/acceptanceTests/java/io/airbyte/test/acceptance/BasicAcceptanceTests.java
@@ -282,9 +282,9 @@ void testDiscoverSourceSchema() throws ApiException {
 
     final AirbyteCatalog actual = testHarness.discoverSourceSchema(sourceId);
 
-    final Map<String, Map<String, DataType>> fields = ImmutableMap.of(
-        COLUMN_ID, ImmutableMap.of("type", DataType.NUMBER),
-        COLUMN_NAME, ImmutableMap.of("type", DataType.STRING));
+    final Map<String, Map<String, String>> fields = ImmutableMap.of(
+        COLUMN_ID, ImmutableMap.of("type", DataType.NUMBER.getValue(), "airbyte_type", "integer"),
+        COLUMN_NAME, ImmutableMap.of("type", DataType.STRING.getValue()));
     final JsonNode jsonSchema = Jsons.jsonNode(ImmutableMap.builder()
         .put("type", "object")
         .put("properties", fields)