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 4ad39bba03 Bug fix in registry
new b90fb93381 Merge pull request #346 from isururanawaka/metaschedular
4ad39bba03 is described below
commit 4ad39bba035c44255a63209495cf126c827fb970
Author: Isuru Ranawaka <[email protected]>
AuthorDate: Tue Nov 29 07:42:10 2022 -0500
Bug fix in registry
---
.../airavata/registry/api/service/handler/RegistryServerHandler.java | 2 ++
thrift-interface-descriptions/component-cpis/registry-api.thrift | 1 +
2 files changed, 3 insertions(+)
diff --git
a/modules/registry/registry-server/registry-api-service/src/main/java/org/apache/airavata/registry/api/service/handler/RegistryServerHandler.java
b/modules/registry/registry-server/registry-api-service/src/main/java/org/apache/airavata/registry/api/service/handler/RegistryServerHandler.java
index d50188d86e..913cf599bc 100644
---
a/modules/registry/registry-server/registry-api-service/src/main/java/org/apache/airavata/registry/api/service/handler/RegistryServerHandler.java
+++
b/modules/registry/registry-server/registry-api-service/src/main/java/org/apache/airavata/registry/api/service/handler/RegistryServerHandler.java
@@ -976,6 +976,7 @@ public class RegistryServerHandler implements
RegistryService.Iface {
}
}
+
@Override
public List<ProcessModel> getProcessListInState(ProcessState processState)
throws RegistryServiceException, TException {
try {
@@ -989,6 +990,7 @@ public class RegistryServerHandler implements
RegistryService.Iface {
break;
}
offset = offset + processModels.size() - 1;
+ receivedCount +=processModels.size();
for (ProcessModel processModel : processModels) {
ProcessStatus processStatus =
processStatusRepository.getProcessStatus(processModel.getProcessId());
if
(processStatus.getState().name().equals(processState.name())) {
diff --git a/thrift-interface-descriptions/component-cpis/registry-api.thrift
b/thrift-interface-descriptions/component-cpis/registry-api.thrift
index d02f62c9fe..3963142710 100644
--- a/thrift-interface-descriptions/component-cpis/registry-api.thrift
+++ b/thrift-interface-descriptions/component-cpis/registry-api.thrift
@@ -758,6 +758,7 @@ service RegistryService extends base_api.BaseAPI {
status_models.ProcessStatus getProcessStatus(1: required string
processId)
throws (1:
registry_api_errors.RegistryServiceException rse)
+
list<process_model.ProcessModel> getProcessListInState(1: required
status_models.ProcessState processState)
throws (1:
registry_api_errors.RegistryServiceException rse)