[airavata] branch param-sweep updated: Logging improvements for DataParsingTask

[di...@apache.org]

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

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


The following commit(s) were added to refs/heads/param-sweep by this push:
     new 8ad5566  Logging improvements for DataParsingTask
8ad5566 is described below

commit 8ad55661a0d676c3a376e7a9b0c915869fb826e8
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Thu Aug 27 17:39:47 2020 -0400

    Logging improvements for DataParsingTask
---
 .../airavata/helix/impl/task/parsing/DataParsingTask.java     | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/DataParsingTask.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/DataParsingTask.java
index 5b4e2fd..d12b0f2 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/DataParsingTask.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/DataParsingTask.java
@@ -111,6 +111,8 @@ public class DataParsingTask extends AbstractTask {
         try {
 
             Parser parser = getRegistryServiceClient().getParser(parserId, gatewayId);
+            logger.info("Loading parser with id {}", parser.getId());
+
             String containerId = getTaskId() + "_PARSER_"+ parser.getId();
             containerId = containerId.replace(" ", "-");
 
@@ -128,7 +130,12 @@ public class DataParsingTask extends AbstractTask {
 
                     ParsingTaskInput parsingTaskInput = filteredInputOptional.get();
 
-                    String inputVal = parsingTaskInput.getValue() != null ? parsingTaskInput.getValue() : getContextVariable(parsingTaskInput.getContextVariableName());
+                    String inputVal = parsingTaskInput.getValue() != null ?
+                                                parsingTaskInput.getValue() :
+                                                getContextVariable(parsingTaskInput.getContextVariableName());
+
+                    logger.info("Processing parser input {} with type {} and with value {}",
+                                                    parsingTaskInput.getName(), parserInput.getType().name(), inputVal);
 
                     if ("PROPERTY".equals(parsingTaskInput.getType())) {
                         properties.put(parsingTaskInput.getName(), inputVal);
@@ -142,6 +149,8 @@ public class DataParsingTask extends AbstractTask {
                             throw new TaskOnFailException("Data product uri could not be null or empty for input "
                                     + parsingTaskInput.getId() + " with name " + parserInput.getName(), true, null);
                         }
+
+                        logger.info("Using data product uri {} for input name {}", inputDataProductUri, parserInput.getName());
                         DataProductModel inputDataProduct = getRegistryServiceClient().getDataProduct(inputDataProductUri);
                         List<DataReplicaLocationModel> replicaLocations = inputDataProduct.getReplicaLocations();