[airavata] branch staging updated: AIRAVATA-3233 Skip staging optional inputs that have no value

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

machristie pushed a commit to branch staging
in repository https://gitbox.apache.org/repos/asf/airavata.git


The following commit(s) were added to refs/heads/staging by this push:
     new 4caefaf  AIRAVATA-3233 Skip staging optional inputs that have no value
4caefaf is described below

commit 4caefaf82bf952353f87f87de242c67ee036f17b
Author: Marcus Christie <ma...@apache.org>
AuthorDate: Mon Oct 21 21:06:03 2019 -0400

    AIRAVATA-3233 Skip staging optional inputs that have no value
---
 .../apache/airavata/orchestrator/cpi/impl/SimpleOrchestratorImpl.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/modules/orchestrator/orchestrator-core/src/main/java/org/apache/airavata/orchestrator/cpi/impl/SimpleOrchestratorImpl.java b/modules/orchestrator/orchestrator-core/src/main/java/org/apache/airavata/orchestrator/cpi/impl/SimpleOrchestratorImpl.java
index c81736f..a8ac801 100644
--- a/modules/orchestrator/orchestrator-core/src/main/java/org/apache/airavata/orchestrator/cpi/impl/SimpleOrchestratorImpl.java
+++ b/modules/orchestrator/orchestrator-core/src/main/java/org/apache/airavata/orchestrator/cpi/impl/SimpleOrchestratorImpl.java
@@ -417,6 +417,9 @@ public class SimpleOrchestratorImpl extends AbstractOrchestrator{
                         break;
                     case URI:
                     case URI_COLLECTION:
+                        if ((processInput.getValue() == null || processInput.getValue() == "") && !processInput.isIsRequired()) {
+                            logger.debug("Skipping input data staging task for {} since value is empty and not required", processInput.getName());
+                        }
                         final RegistryService.Client registryClient = getRegistryServiceClient();
                         try {
                             TaskModel inputDataStagingTask = getInputDataStagingTask(registryClient, processModel, processInput, gatewayId);