This is an automated email from the ASF dual-hosted git repository.
yasith pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata.git
The following commit(s) were added to refs/heads/master by this push:
new b12d6b3afe manually call .setTimeOfStateChange() for
procesStatusEntity and jobStatusEntity
b12d6b3afe is described below
commit b12d6b3afeba89a114e3107f53161657c2120cda
Author: yasithdev <[email protected]>
AuthorDate: Mon Jul 14 17:08:20 2025 -0500
manually call .setTimeOfStateChange() for procesStatusEntity and
jobStatusEntity
---
.../registry/core/repositories/expcatalog/JobRepository.java | 2 ++
.../registry/core/repositories/expcatalog/ProcessRepository.java | 7 ++++---
2 files changed, 6 insertions(+), 3 deletions(-)
diff --git
a/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/JobRepository.java
b/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/JobRepository.java
index c3b4fb24b1..913f9ad137 100644
---
a/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/JobRepository.java
+++
b/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/JobRepository.java
@@ -24,6 +24,7 @@ import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import org.apache.airavata.common.utils.AiravataUtils;
import org.apache.airavata.model.commons.airavata_commonsConstants;
import org.apache.airavata.model.job.JobModel;
import org.apache.airavata.registry.core.entities.expcatalog.JobEntity;
@@ -85,6 +86,7 @@ public class JobRepository extends
ExpCatAbstractRepository<JobModel, JobEntity,
jobEntity.getJobStatuses().forEach(jobStatusEntity -> {
jobStatusEntity.setJobId(jobId);
jobStatusEntity.setTaskId(taskId);
+
jobStatusEntity.setTimeOfStateChange(AiravataUtils.getCurrentTimestamp());
});
}
}
diff --git
a/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/ProcessRepository.java
b/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/ProcessRepository.java
index 497491fe44..72fdd2f081 100644
---
a/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/ProcessRepository.java
+++
b/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/ProcessRepository.java
@@ -107,9 +107,10 @@ public class ProcessRepository extends
ExpCatAbstractRepository<ProcessModel, Pr
if (processEntity.getProcessStatuses() != null) {
logger.debug("Populating the Primary Key of ProcessStatus objects
for the Process");
- processEntity
- .getProcessStatuses()
- .forEach(processStatusEntity ->
processStatusEntity.setProcessId(processId));
+ processEntity.getProcessStatuses().forEach(processStatusEntity -> {
+ processStatusEntity.setProcessId(processId);
+
processStatusEntity.setTimeOfStateChange(AiravataUtils.getCurrentTimestamp());
+ });
}
if (processEntity.getProcessErrors() != null) {