[airavata] branch develop updated: bug fix in data analyzer

[isjarana]

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

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


The following commit(s) were added to refs/heads/develop by this push:
     new 8eef0e1433 bug fix in data analyzer
     new 2dc66ff72e Merge pull request #384 from isururanawaka/metaschedular
8eef0e1433 is described below

commit 8eef0e1433af29fa1afd90ad0c03c93e0a298397
Author: Isuru Ranawaka <irjan...@gmail.com>
AuthorDate: Thu Feb 2 12:33:07 2023 -0500

    bug fix in data analyzer
---
 .../metascheduler/metadata/analyzer/impl/DataAnalyzerImpl.java     | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/modules/airavata-metascheduler/metadata-analyzer/src/main/java/org/apache/airavata/metascheduler/metadata/analyzer/impl/DataAnalyzerImpl.java
 
b/modules/airavata-metascheduler/metadata-analyzer/src/main/java/org/apache/airavata/metascheduler/metadata/analyzer/impl/DataAnalyzerImpl.java
index 294c385f4d..53c2948051 100644
--- 
a/modules/airavata-metascheduler/metadata-analyzer/src/main/java/org/apache/airavata/metascheduler/metadata/analyzer/impl/DataAnalyzerImpl.java
+++ 
b/modules/airavata-metascheduler/metadata-analyzer/src/main/java/org/apache/airavata/metascheduler/metadata/analyzer/impl/DataAnalyzerImpl.java
@@ -56,10 +56,11 @@ public class DataAnalyzerImpl implements DataAnalyzer {
 
             Map<String, Double> timeDistribution = 
client.getAVGTimeDistribution(gateway,15);
 
-            if(!timeDistribution.isEmpty() && timeDistribution.size()==3) {
-                LOGGER.info("orch Time:  " + timeDistribution.get("orchTime") 
+ " queued Time "
-                        + timeDistribution.get("queuedTime") + " helix Time " 
+ timeDistribution.get("helix"));
+            String msg ="";
+            for(Map.Entry<String, Double> entry: timeDistribution.entrySet()){
+                msg = " avg time "+entry.getKey()+"  : "+entry.getValue();
             }
+            LOGGER.info(msg);
 
         } catch (Exception ex) {
             String msg = "Error occurred while executing data analyzer" + 
ex.getMessage();