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 ca1343b325 run spotless:apply
ca1343b325 is described below
commit ca1343b325d3d0a0121b4b4a9a1ad20bae0cc6a6
Author: yasithdev <[email protected]>
AuthorDate: Tue Jul 15 01:57:36 2025 -0500
run spotless:apply
---
.../helix/impl/workflow/PostWorkflowManager.java | 28 +++++++++++++++++-----
.../entities/workflowcatalog/WorkflowEntity.java | 1 -
.../sharing/registry/db/entities/EntityEntity.java | 1 -
.../sharing/registry/db/entities/UserEntity.java | 1 -
4 files changed, 22 insertions(+), 9 deletions(-)
diff --git
a/airavata-api/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java
b/airavata-api/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java
index a0dc3be935..ccaf671aed 100644
---
a/airavata-api/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java
+++
b/airavata-api/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java
@@ -141,7 +141,9 @@ public class PostWorkflowManager extends WorkflowManager {
getRegistryClientPool().returnResource(registryClient);
if (experimentModel != null) {
-
jobModel.getJobStatuses().sort(Comparator.comparingLong(JobStatus::getTimeOfStateChange).reversed());
+ jobModel.getJobStatuses()
+
.sort(Comparator.comparingLong(JobStatus::getTimeOfStateChange)
+ .reversed());
JobState currentJobStatus =
jobModel.getJobStatuses().get(0).getJobState();
logger.info("Last known state of job {} is {}", jobId,
jobName);
@@ -155,8 +157,13 @@ public class PostWorkflowManager extends WorkflowManager {
String gateway = experimentModel.getGatewayId();
String experimentId = experimentModel.getExperimentId();
- logger.info("saving JobStatusUpdate<{}>: pid={}, eid={},
gw={}, state={}",
- jobId, processId, experimentId, gateway, jobState);
+ logger.info(
+ "saving JobStatusUpdate<{}>: pid={}, eid={}, gw={},
state={}",
+ jobId,
+ processId,
+ experimentId,
+ gateway,
+ jobState);
saveAndPublishJobStatus(jobId, task, processId, experimentId,
gateway, jobState);
// TODO get cluster lock before that
@@ -194,7 +201,11 @@ public class PostWorkflowManager extends WorkflowManager {
return false;
}
} catch (Exception e) {
- logger.error("Failed to process job: {}, with status : {}",
jobStatusResult.getJobId(), jobStatusResult.getState().name(), e);
+ logger.error(
+ "Failed to process job: {}, with status : {}",
+ jobStatusResult.getJobId(),
+ jobStatusResult.getState().name(),
+ e);
getRegistryClientPool().returnBrokenResource(registryClient);
return false;
}
@@ -215,7 +226,9 @@ public class PostWorkflowManager extends WorkflowManager {
var grpId = processModel.getGroupResourceProfileId();
experimentModel = registryClient.getExperiment(experimentId);
- ResourceType resourceType =
registryClient.getGroupComputeResourcePreference(crId, grpId).getResourceType();
+ ResourceType resourceType = registryClient
+ .getGroupComputeResourcePreference(crId, grpId)
+ .getResourceType();
taskFactory = TaskFactory.getFactory(resourceType);
logger.info("Initialized task factory for resource type {} for
process {}", resourceType, processId);
@@ -344,7 +357,10 @@ public class PostWorkflowManager extends WorkflowManager {
// robustness of the kafka read thread by
avoiding wait timeouts
processingFutures.add(executorCompletionService.submit(() -> {
boolean success = process(record.value());
- logger.info("Status of processing {} :
{}", record.value().getJobId(), success);
+ logger.info(
+ "Status of processing {} : {}",
+ record.value().getJobId(),
+ success);
return success;
}));
diff --git
a/airavata-api/src/main/java/org/apache/airavata/registry/core/entities/workflowcatalog/WorkflowEntity.java
b/airavata-api/src/main/java/org/apache/airavata/registry/core/entities/workflowcatalog/WorkflowEntity.java
index a367828aa1..d925b66b4d 100644
---
a/airavata-api/src/main/java/org/apache/airavata/registry/core/entities/workflowcatalog/WorkflowEntity.java
+++
b/airavata-api/src/main/java/org/apache/airavata/registry/core/entities/workflowcatalog/WorkflowEntity.java
@@ -21,7 +21,6 @@ package
org.apache.airavata.registry.core.entities.workflowcatalog;
import jakarta.persistence.*;
import java.io.Serializable;
-import java.nio.ByteBuffer;
import java.sql.Timestamp;
import java.util.List;
diff --git
a/airavata-api/src/main/java/org/apache/airavata/sharing/registry/db/entities/EntityEntity.java
b/airavata-api/src/main/java/org/apache/airavata/sharing/registry/db/entities/EntityEntity.java
index 7e5c140245..18af04b1dc 100644
---
a/airavata-api/src/main/java/org/apache/airavata/sharing/registry/db/entities/EntityEntity.java
+++
b/airavata-api/src/main/java/org/apache/airavata/sharing/registry/db/entities/EntityEntity.java
@@ -20,7 +20,6 @@
package org.apache.airavata.sharing.registry.db.entities;
import jakarta.persistence.*;
-import java.nio.ByteBuffer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/airavata-api/src/main/java/org/apache/airavata/sharing/registry/db/entities/UserEntity.java
b/airavata-api/src/main/java/org/apache/airavata/sharing/registry/db/entities/UserEntity.java
index 328fa61c5b..2ddc649609 100644
---
a/airavata-api/src/main/java/org/apache/airavata/sharing/registry/db/entities/UserEntity.java
+++
b/airavata-api/src/main/java/org/apache/airavata/sharing/registry/db/entities/UserEntity.java
@@ -20,7 +20,6 @@
package org.apache.airavata.sharing.registry.db.entities;
import jakarta.persistence.*;
-import java.nio.ByteBuffer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
