When fetching intermediate URI_COLLECTION, update process output with data product URIs
@@ -316,9 +316,16 @@ public abstract class AiravataTask extends AbstractTask {
productUris.add(productUri);
}
expOutput.setValue(String.join(",", productUris));
+ if (!skipExperimentStatusPublish) {
getRegistryServiceClient().addExperimentProcessOutputs("EXPERIMENT_OUTPUT",
Collections.singletonList(expOutput), experimentId);
}
+
+ if (!skipProcessStatusPublish) {
+ getRegistryServiceClient().addExperimentProcessOutputs("PROCESS_OUTPUT",
+ Collections.singletonList(expOutput), processId);
+ }
+ }
}
}
