You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2021/09/02 19:23:14 UTC

[airavata-data-lake] branch master updated: Minor logging improvement

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

dimuthuupe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata-data-lake.git


The following commit(s) were added to refs/heads/master by this push:
     new 6232bd0  Minor logging improvement
6232bd0 is described below

commit 6232bd0f29831d556f8134baff9218bc8aeb9aa7
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Thu Sep 2 15:23:06 2021 -0400

    Minor logging improvement
---
 .../workflow/engine/task/impl/GenericDataParsingTask.java            | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/data-orchestrator/workflow-engine/workflow-engine-core/src/main/java/org/apache/airavata/datalake/orchestrator/workflow/engine/task/impl/GenericDataParsingTask.java b/data-orchestrator/workflow-engine/workflow-engine-core/src/main/java/org/apache/airavata/datalake/orchestrator/workflow/engine/task/impl/GenericDataParsingTask.java
index 919d36f..acb73d1 100644
--- a/data-orchestrator/workflow-engine/workflow-engine-core/src/main/java/org/apache/airavata/datalake/orchestrator/workflow/engine/task/impl/GenericDataParsingTask.java
+++ b/data-orchestrator/workflow-engine/workflow-engine-core/src/main/java/org/apache/airavata/datalake/orchestrator/workflow/engine/task/impl/GenericDataParsingTask.java
@@ -113,11 +113,12 @@ public class GenericDataParsingTask extends BlockingTask {
             }
 
             if (path.startsWith("$")) {
-                path = getUserContent(path.substring(1), Scope.WORKFLOW);
-                if (path == null) {
+                String derivedPath = getUserContent(path.substring(1), Scope.WORKFLOW);
+                if (derivedPath == null) {
                     logger.error("No value in context to path {} for {}", path, dpi.getParserInputInterfaceId());
                     return new TaskResult(TaskResult.Status.FAILED, "No value specified in context for path");
                 }
+                path = derivedPath;
             }
 
             try {