diff --git a/lampi-siirtaja-container/lampi-siirtaja/src/main/java/fi/oph/opintopolku/ovara/service/LampiSiirtajaService.java b/lampi-siirtaja-container/lampi-siirtaja/src/main/java/fi/oph/opintopolku/ovara/service/LampiSiirtajaService.java index 44e7d2b..5b75a1b 100644 --- a/lampi-siirtaja-container/lampi-siirtaja/src/main/java/fi/oph/opintopolku/ovara/service/LampiSiirtajaService.java +++ b/lampi-siirtaja-container/lampi-siirtaja/src/main/java/fi/oph/opintopolku/ovara/service/LampiSiirtajaService.java @@ -25,6 +25,8 @@ public LampiSiirtajaService(final Config config) { public void run() throws Exception { DatabaseToS3 db = new DatabaseToS3(config); + List manifestItems = new ArrayList<>(); + Stream.of("pub", "dw") // Stream.of("pub") .forEach( @@ -38,7 +40,6 @@ public void run() throws Exception { db.exportTablesToS3(schemaName, tableNames); LOG.info("Scheman {} datojen vienti Ovaran AWS S3-ämpäriin valmistui", schemaName); LOG.info("Aloitetaan scheman {} tiedostojen siirto Lammen S3-ämpäriin", schemaName); - List manifestItems = new ArrayList<>(); exportToS3Results.forEach( (tableName, s3ExportResult) -> { int numberOfFiles = s3ExportResult.getFiles_uploaded(); @@ -62,13 +63,13 @@ public void run() throws Exception { throw new RuntimeException(e); } }); - LOG.info("Siirretään manifest.json Lampeen"); - LampiS3Transfer manifestTransfer = new LampiS3Transfer(config); - manifestTransfer.uploadManifest(manifestItems); LOG.info("Scheman {} tiedostojen siirto Lammen S3-ämpäriin valmistui", schemaName); } catch (Exception e) { throw new RuntimeException(e); } }); + LOG.info("Siirretään manifest.json Lampeen"); + LampiS3Transfer manifestTransfer = new LampiS3Transfer(config); + manifestTransfer.uploadManifest(manifestItems); } }