diff --git a/airbyte-config/config-models/src/main/resources/types/StandardDestinationDefinition.yaml b/airbyte-config/config-models/src/main/resources/types/StandardDestinationDefinition.yaml index 375dc2878c15..b69c82a343bd 100644 --- a/airbyte-config/config-models/src/main/resources/types/StandardDestinationDefinition.yaml +++ b/airbyte-config/config-models/src/main/resources/types/StandardDestinationDefinition.yaml @@ -55,3 +55,6 @@ properties: format: date resourceRequirements: "$ref": ActorDefinitionResourceRequirements.yaml + protocolVersion: + type: string + description: the Airbyte Protocol version supported by the connector diff --git a/airbyte-config/config-models/src/main/resources/types/StandardSourceDefinition.yaml b/airbyte-config/config-models/src/main/resources/types/StandardSourceDefinition.yaml index eada43f89766..b08e36599c4e 100644 --- a/airbyte-config/config-models/src/main/resources/types/StandardSourceDefinition.yaml +++ b/airbyte-config/config-models/src/main/resources/types/StandardSourceDefinition.yaml @@ -62,3 +62,6 @@ properties: format: date resourceRequirements: "$ref": ActorDefinitionResourceRequirements.yaml + protocolVersion: + type: string + description: the Airbyte Protocol version supported by the connector diff --git a/airbyte-config/config-persistence/src/main/java/io/airbyte/config/persistence/ConfigWriter.java b/airbyte-config/config-persistence/src/main/java/io/airbyte/config/persistence/ConfigWriter.java index 83969135dcaf..e21b039d3bbd 100644 --- a/airbyte-config/config-persistence/src/main/java/io/airbyte/config/persistence/ConfigWriter.java +++ b/airbyte-config/config-persistence/src/main/java/io/airbyte/config/persistence/ConfigWriter.java @@ -50,6 +50,7 @@ static void writeStandardSourceDefinition(final List c : Enums.toEnum(standardSourceDefinition.getSourceType().value(), SourceType.class).orElseThrow()) .set(Tables.ACTOR_DEFINITION.SPEC, JSONB.valueOf(Jsons.serialize(standardSourceDefinition.getSpec()))) + .set(Tables.ACTOR_DEFINITION.PROTOCOL_VERSION, standardSourceDefinition.getProtocolVersion()) .set(Tables.ACTOR_DEFINITION.TOMBSTONE, standardSourceDefinition.getTombstone()) .set(Tables.ACTOR_DEFINITION.PUBLIC, standardSourceDefinition.getPublic()) .set(Tables.ACTOR_DEFINITION.CUSTOM, standardSourceDefinition.getCustom()) @@ -79,6 +80,7 @@ static void writeStandardSourceDefinition(final List c : Enums.toEnum(standardSourceDefinition.getSourceType().value(), SourceType.class).orElseThrow()) .set(Tables.ACTOR_DEFINITION.SPEC, JSONB.valueOf(Jsons.serialize(standardSourceDefinition.getSpec()))) + .set(Tables.ACTOR_DEFINITION.PROTOCOL_VERSION, standardSourceDefinition.getProtocolVersion()) .set(Tables.ACTOR_DEFINITION.TOMBSTONE, standardSourceDefinition.getTombstone() != null && standardSourceDefinition.getTombstone()) .set(Tables.ACTOR_DEFINITION.PUBLIC, standardSourceDefinition.getPublic()) .set(Tables.ACTOR_DEFINITION.CUSTOM, standardSourceDefinition.getCustom()) @@ -115,6 +117,7 @@ static void writeStandardDestinationDefinition(final List