Ensure Local Secret Persistence is Initialized (#21329)

* Formatting * Ensure that local persistence is initialized
airbytehq · Jan 12, 2023 · 5bc38f0 · 5bc38f0
1 parent 94c84f7
commit 5bc38f0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/.../main/java/io/airbyte/config/persistence/split_secrets/LocalTestingSecretPersistence.java b/.../main/java/io/airbyte/config/persistence/split_secrets/LocalTestingSecretPersistence.java
@@ -36,6 +36,7 @@ public void initialize() throws SQLException {
   @Override
   public Optional<String> read(final SecretCoordinate coordinate) {
     return Exceptions.toRuntime(() -> this.configDatabase.query(ctx -> {
+      initialize();
       final var result = ctx.fetch("SELECT payload FROM secrets WHERE coordinate = ?;", coordinate.getFullCoordinate());
       if (result.size() == 0) {
         return Optional.empty();
@@ -48,6 +49,7 @@ public Optional<String> read(final SecretCoordinate coordinate) {
   @Override
   public void write(final SecretCoordinate coordinate, final String payload) {
     Exceptions.toRuntime(() -> this.configDatabase.query(ctx -> {
+      initialize();
       ctx.query("INSERT INTO secrets(coordinate,payload) VALUES(?, ?) ON CONFLICT (coordinate) DO UPDATE SET payload = ?;",
           coordinate.getFullCoordinate(), payload, payload, coordinate.getFullCoordinate()).execute();
       return null;

diff --git a/docker-compose-cloud.buildx.yaml b/docker-compose-cloud.buildx.yaml
@@ -35,7 +35,7 @@ services:
           - airbyte/server:${ALT_TAG:-${VERSION}}
         platforms:
           - linux/amd64
-          - linux/arm64          
+          - linux/arm64
   worker:
     image: airbyte/worker:${VERSION}
     build: