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
commit 76f16fc603c69544175165c7da518a6fdc80852d Author: yasithdev <[email protected]> AuthorDate: Mon Jul 14 09:03:16 2025 -0500 use current timestsamp when saving process statuses --- .../core/repositories/expcatalog/ProcessRepository.java | 3 +++ .../core/repositories/expcatalog/TaskRepository.java | 13 +++++++++++-- 2 files changed, 14 insertions(+), 2 deletions(-) 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 0f7316f2ee..d37d88b155 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 @@ -25,6 +25,8 @@ 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.process.ProcessModel; import org.apache.airavata.model.scheduling.ComputationalResourceSchedulingModel; @@ -120,6 +122,7 @@ public class ProcessRepository extends ExpCatAbstractRepository<ProcessModel, Pr logger.debug("Populating the Primary Key of Task objects for the Process"); processEntity.getTasks().forEach(taskEntity -> { taskEntity.setParentProcessId(processId); + taskEntity.setCreationTime(AiravataUtils.getCurrentTimestamp()); taskRepository.populateParentIds(taskEntity); }); } diff --git a/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/TaskRepository.java b/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/TaskRepository.java index 5facb7e1d8..2c31cedae1 100644 --- a/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/TaskRepository.java +++ b/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/TaskRepository.java @@ -20,10 +20,13 @@ package org.apache.airavata.registry.core.repositories.expcatalog; import com.github.dozermapper.core.Mapper; + 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.task.TaskModel; import org.apache.airavata.registry.core.entities.expcatalog.TaskEntity; @@ -87,12 +90,18 @@ public class TaskRepository extends ExpCatAbstractRepository<TaskModel, TaskEnti if (taskEntity.getTaskStatuses() != null) { logger.debug("Populating the Primary Key of TaskStatus objects for the Task"); - taskEntity.getTaskStatuses().forEach(taskStatusEntity -> taskStatusEntity.setTaskId(taskId)); + taskEntity.getTaskStatuses().forEach(taskStatusEntity -> { + taskStatusEntity.setTaskId(taskId); + taskStatusEntity.setTimeOfStateChange(AiravataUtils.getCurrentTimestamp()); + }); } if (taskEntity.getTaskErrors() != null) { logger.debug("Populating the Primary Key of TaskError objects for the Task"); - taskEntity.getTaskErrors().forEach(taskErrorEntity -> taskErrorEntity.setTaskId(taskId)); + taskEntity.getTaskErrors().forEach(taskErrorEntity -> { + taskErrorEntity.setTaskId(taskId); + taskErrorEntity.setCreationTime(AiravataUtils.getCurrentTimestamp()); + }); } if (taskEntity.getJobs() != null) {
