Output normalization summary from NormalizationJobOrchestrator

airbytehq · Apr 15, 2022 · 7b1afef · 7b1afef
1 parent 245e617
commit 7b1afef
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...strator/src/main/java/io/airbyte/container_orchestrator/NormalizationJobOrchestrator.java b/...strator/src/main/java/io/airbyte/container_orchestrator/NormalizationJobOrchestrator.java
@@ -4,8 +4,10 @@
 
 package io.airbyte.container_orchestrator;
 
+import io.airbyte.commons.json.Jsons;
 import io.airbyte.config.Configs;
 import io.airbyte.config.NormalizationInput;
+import io.airbyte.config.NormalizationSummary;
 import io.airbyte.scheduler.models.IntegrationLauncherConfig;
 import io.airbyte.scheduler.models.JobRunConfig;
 import io.airbyte.workers.DefaultNormalizationWorker;
@@ -65,9 +67,9 @@ public Optional<String> runJob() throws Exception {
 
     log.info("Running normalization worker...");
     final Path jobRoot = WorkerUtils.getJobRoot(configs.getWorkspaceRoot(), jobRunConfig.getJobId(), jobRunConfig.getAttemptId());
-    normalizationWorker.run(normalizationInput, jobRoot);
+    final NormalizationSummary normalizationSummary = normalizationWorker.run(normalizationInput, jobRoot);
 
-    return Optional.empty();
+    return Optional.of(Jsons.serialize(normalizationSummary));
   }
 
 }