Use internal method

airbytehq · Sep 4, 2021 · cbb15fd · cbb15fd
1 parent 950b2e6
commit cbb15fd
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ig/persistence/src/main/java/io/airbyte/config/persistence/DatabaseConfigPersistence.java b/...ig/persistence/src/main/java/io/airbyte/config/persistence/DatabaseConfigPersistence.java
@@ -338,8 +338,7 @@ private <T> ConnectorCounter updateConnectorDefinitions(DSLContext ctx,
       }
 
       if (!connectorRepositoryToIdVersionMap.containsKey(repository)) {
-        writeConfig(configType, configType.getId(latestDefinition), latestDefinition);
-        newCount += 1;
+        newCount += insertConfigRecord(ctx, timestamp, configType.name(), configJson, configType.getIdFieldName());
         continue;
       }