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 241ad912c1 Add process
new 68f4d3a9d0 Merge pull request #383 from isururanawaka/metaschedular
241ad912c1 is described below
commit 241ad912c1f0e2c4d489219b104d55774c5a8cbc
Author: Isuru Ranawaka <[email protected]>
AuthorDate: Thu Feb 2 09:32:19 2023 -0500
Add process
---
.../registry/core/repositories/expcatalog/ProcessRepository.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git
a/modules/registry/registry-core/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/ProcessRepository.java
b/modules/registry/registry-core/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/ProcessRepository.java
index d8c6c37876..f40cf18201 100644
---
a/modules/registry/registry-core/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/ProcessRepository.java
+++
b/modules/registry/registry-core/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/ProcessRepository.java
@@ -35,6 +35,7 @@ import org.dozer.Mapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -205,13 +206,13 @@ public class ProcessRepository extends
ExpCatAbstractRepository<ProcessModel, Pr
List<Object> helixTimeList =
processRepository.selectWithNativeQuery(QueryConstants.FIND_AVG_TIME_HELIX_NATIVE_QUERY,
gatewayId,String.valueOf(searchTime));
if(orchTimeList.size()>0 && orchTimeList.get(0) != null){
-
timeDistributions.put(DBConstants.MetaData.ORCH_TIME,Double.parseDouble((String)
orchTimeList.get(0)));
+ timeDistributions.put(DBConstants.MetaData.ORCH_TIME,
((BigDecimal)orchTimeList.get(0)).doubleValue());
}
if(queueingTimeList.size()>0 && queueingTimeList.get(0) != null){
-
timeDistributions.put(DBConstants.MetaData.QUEUED_TIME,Double.parseDouble((String)
queueingTimeList.get(0)));
+
timeDistributions.put(DBConstants.MetaData.QUEUED_TIME,((BigDecimal)queueingTimeList.get(0)).doubleValue());
}
if(helixTimeList.size()>0 && helixTimeList.get(0) != null){
-
timeDistributions.put(DBConstants.MetaData.HELIX,Double.parseDouble((String)
helixTimeList.get(0)));
+
timeDistributions.put(DBConstants.MetaData.HELIX,((BigDecimal)helixTimeList.get(0)).doubleValue());
}
return timeDistributions;
}