Skip to content

Commit 76f16fc

Browse files
committed
use current timestsamp when saving process statuses
1 parent aad57d0 commit 76f16fc

2 files changed

Lines changed: 14 additions & 2 deletions

File tree

airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/ProcessRepository.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,8 @@
2525
import java.util.HashMap;
2626
import java.util.List;
2727
import java.util.Map;
28+
29+
import org.apache.airavata.common.utils.AiravataUtils;
2830
import org.apache.airavata.model.commons.airavata_commonsConstants;
2931
import org.apache.airavata.model.process.ProcessModel;
3032
import org.apache.airavata.model.scheduling.ComputationalResourceSchedulingModel;
@@ -120,6 +122,7 @@ protected void populateParentIds(ProcessEntity processEntity) {
120122
logger.debug("Populating the Primary Key of Task objects for the Process");
121123
processEntity.getTasks().forEach(taskEntity -> {
122124
taskEntity.setParentProcessId(processId);
125+
taskEntity.setCreationTime(AiravataUtils.getCurrentTimestamp());
123126
taskRepository.populateParentIds(taskEntity);
124127
});
125128
}

airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/expcatalog/TaskRepository.java

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,10 +20,13 @@
2020
package org.apache.airavata.registry.core.repositories.expcatalog;
2121

2222
import com.github.dozermapper.core.Mapper;
23+
2324
import java.util.ArrayList;
2425
import java.util.HashMap;
2526
import java.util.List;
2627
import java.util.Map;
28+
29+
import org.apache.airavata.common.utils.AiravataUtils;
2730
import org.apache.airavata.model.commons.airavata_commonsConstants;
2831
import org.apache.airavata.model.task.TaskModel;
2932
import org.apache.airavata.registry.core.entities.expcatalog.TaskEntity;
@@ -87,12 +90,18 @@ protected void populateParentIds(TaskEntity taskEntity) {
8790

8891
if (taskEntity.getTaskStatuses() != null) {
8992
logger.debug("Populating the Primary Key of TaskStatus objects for the Task");
90-
taskEntity.getTaskStatuses().forEach(taskStatusEntity -> taskStatusEntity.setTaskId(taskId));
93+
taskEntity.getTaskStatuses().forEach(taskStatusEntity -> {
94+
taskStatusEntity.setTaskId(taskId);
95+
taskStatusEntity.setTimeOfStateChange(AiravataUtils.getCurrentTimestamp());
96+
});
9197
}
9298

9399
if (taskEntity.getTaskErrors() != null) {
94100
logger.debug("Populating the Primary Key of TaskError objects for the Task");
95-
taskEntity.getTaskErrors().forEach(taskErrorEntity -> taskErrorEntity.setTaskId(taskId));
101+
taskEntity.getTaskErrors().forEach(taskErrorEntity -> {
102+
taskErrorEntity.setTaskId(taskId);
103+
taskErrorEntity.setCreationTime(AiravataUtils.getCurrentTimestamp());
104+
});
96105
}
97106

98107
if (taskEntity.getJobs() != null) {

0 commit comments

Comments
 (0)