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 995d8d1689 fix bug in VALID_UNTIL_TIME column value not set
995d8d1689 is described below
commit 995d8d1689d22a66e0a3911f6540396e45b17138
Author: yasithdev <[email protected]>
AuthorDate: Tue Jul 15 04:27:25 2025 -0500
fix bug in VALID_UNTIL_TIME column value not set
---
.../core/repositories/replicacatalog/DataProductRepository.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/replicacatalog/DataProductRepository.java
b/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/replicacatalog/DataProductRepository.java
index e1c8e620dc..3d0dadbbfb 100644
---
a/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/replicacatalog/DataProductRepository.java
+++
b/airavata-api/src/main/java/org/apache/airavata/registry/core/repositories/replicacatalog/DataProductRepository.java
@@ -21,6 +21,7 @@ package
org.apache.airavata.registry.core.repositories.replicacatalog;
import com.github.dozermapper.core.Mapper;
import java.sql.Timestamp;
+import java.time.Duration;
import java.util.*;
import org.apache.airavata.model.data.replica.DataProductModel;
import org.apache.airavata.model.data.replica.DataProductType;
@@ -82,6 +83,8 @@ public class DataProductRepository extends
RepCatAbstractRepository<DataProductM
}
if (dataProductEntity.getReplicaLocations() != null) {
+ // set replica validity for 7 days
+ final Timestamp validUntilTime = new
Timestamp(currentTime.getTime() + Duration.ofDays(7).toMillis());
logger.debug("Populating the product URI for ReplicaLocations
objects for the Data Product");
dataProductEntity.getReplicaLocations().forEach(dataReplicaLocationEntity -> {
dataReplicaLocationEntity.setProductUri(productUri);
@@ -92,6 +95,7 @@ public class DataProductRepository extends
RepCatAbstractRepository<DataProductM
dataReplicaLocationEntity.setCreationTime(currentTime);
}
dataReplicaLocationEntity.setLastModifiedTime(currentTime);
+ dataReplicaLocationEntity.setValidUntilTime(validUntilTime);
});
}