You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by is...@apache.org on 2022/12/28 22:24:14 UTC
[airavata] branch develop updated: delete by jobPK
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 b84e425be3 delete by jobPK
new 9f398dc98f Merge pull request #363 from isururanawaka/metaschedular
b84e425be3 is described below
commit b84e425be3005580fdcdf851733634504ceda2f5
Author: Isuru Ranawaka <ir...@gmail.com>
AuthorDate: Wed Dec 28 17:23:16 2022 -0500
delete by jobPK
---
.../registry/api/service/handler/RegistryServerHandler.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
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 f6c7bb7a31..79e0baad40 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
@@ -887,12 +887,12 @@ public class RegistryServerHandler implements RegistryService.Iface {
public void deleteJobs(String processId) throws RegistryServiceException, TException {
try {
List<JobModel> jobs = jobRepository.getJobList(Constants.FieldConstants.JobConstants.PROCESS_ID, processId);
- jobs.forEach(job->{
+ for (JobModel jobModel: jobs) {
JobPK jobPK = new JobPK();
- jobPK.setJobId(job.getJobId());
- jobPK.setTaskId(job.getTaskId());
- jobRepository.delete(jobPK);
- });
+ jobPK.setJobId(jobModel.getJobId());
+ jobPK.setTaskId(jobModel.getTaskId());
+ jobRepository.removeJob(jobPK);
+ }
} catch (Exception e) {
logger.error(processId, "Error while deleting job ", e);
AiravataSystemException exception = new AiravataSystemException();