palautettu migraatiolambda deploy workflowhun ja siivouslambdaan idem…

…potency keyn siivous, uusi kantamigraatio paremman idempotency key indexin luontiin
Opetushallitus · Nov 13, 2024 · d52359a · d52359a
1 parent ede9bf0
commit d52359a
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/.github/workflows/deploy.yml b/.github/workflows/deploy.yml
@@ -65,10 +65,10 @@ jobs:
           mkdir -p ./target/static/_next
           cp -R ./target/viestinvalitys-raportointi/.next/static ./target/static/_next/static
 
-#      - name: Run Flyway Migrations
-#        run: |
-#          cd cdk
-#          cdk deploy MigraatioStack --require-approval never -c "environment=${{ inputs.environment }}"
+      - name: Run Flyway Migrations
+        run: |
+          cd cdk
+          cdk deploy MigraatioStack --require-approval never -c "environment=${{ inputs.environment }}"
 
       - name: Deploy Lambdas
         run: |

diff --git a/lambdat/siivous/src/main/scala/fi/oph/viestinvalitys/siivous/LambdaHandler.scala b/lambdat/siivous/src/main/scala/fi/oph/viestinvalitys/siivous/LambdaHandler.scala
@@ -35,8 +35,8 @@ class LambdaHandler extends RequestHandler[Object, Void] {
         })
       })
 
-      //val poistetutAvaimet = kantaOperaatiot.poistaIdempotencyKeys(Instant.now().minusSeconds(60*60*48))
-      //LOG.info("Poistettiin idempotency-avaimet (" + poistetutAvaimet + " kpl) yli 48h sitten luoduilta viesteiltä")
+      val poistetutAvaimet = kantaOperaatiot.poistaIdempotencyKeys(Instant.now().minusSeconds(60*60*48))
+      LOG.info("Poistettiin idempotency-avaimet (" + poistetutAvaimet + " kpl) yli 48h sitten luoduilta viesteiltä")
 
       null
     })

diff --git a/shared/src/main/resources/flyway/V202411130000__recreate_idempotency_key_index.sql b/shared/src/main/resources/flyway/V202411130000__recreate_idempotency_key_index.sql
@@ -0,0 +1,2 @@
+DROP INDEX IF EXISTS idempotenct_idx;
+CREATE UNIQUE INDEX IF NOT EXISTS idempotency_idx ON viestit (omistaja, idempotency_key) WHERE idempotency_key IS NOT NULL;
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		DROP INDEX IF EXISTS idempotenct_idx;
		CREATE UNIQUE INDEX IF NOT EXISTS idempotency_idx ON viestit (omistaja, idempotency_key) WHERE idempotency_key IS NOT NULL;