You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2025/03/22 10:36:10 UTC
(airavata) 21/21: cleanup code. add placeholders for job monitor email/pw in airavata-server.properties
This is an automated email from the ASF dual-hosted git repository.
lahirujayathilake pushed a commit to branch cybershuttle-dev
in repository https://gitbox.apache.org/repos/asf/airavata.git
commit 22be98dcd9d344997587b74bbadf41e159282e01
Author: yasithdev <ya...@icloud.com>
AuthorDate: Fri Mar 21 23:43:19 2025 +0000
cleanup code. add placeholders for job monitor email/pw in airavata-server.properties
---
.../airavata/helix/impl/task/parsing/ParsingTriggeringTask.java | 6 +++---
.../ide-integration/src/main/resources/airavata-server.properties | 5 ++---
2 files changed, 5 insertions(+), 6 deletions(-)
diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/ParsingTriggeringTask.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/ParsingTriggeringTask.java
index dc1f157d5c..b97835c62d 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/ParsingTriggeringTask.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/ParsingTriggeringTask.java
@@ -19,7 +19,7 @@ import java.util.concurrent.ExecutionException;
@TaskDef(name = "Parsing Triggering Task")
public class ParsingTriggeringTask extends AiravataTask {
- private final static Logger logger = LoggerFactory.getLogger(DataParsingTask.class);
+ private final static Logger logger = LoggerFactory.getLogger(ParsingTriggeringTask.class);
private static Producer<String, ProcessCompletionMessage> producer;
@@ -33,7 +33,7 @@ public class ParsingTriggeringTask extends AiravataTask {
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
StringSerializer.class.getName());
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, ProcessCompletionMessageSerializer.class.getName());
- producer = new KafkaProducer<String, ProcessCompletionMessage>(props);
+ producer = new KafkaProducer<>(props);
}
}
@@ -49,7 +49,7 @@ public class ParsingTriggeringTask extends AiravataTask {
@Override
public TaskResult onRun(TaskHelper helper, TaskContext taskContext) {
- logger.info("Starting parsing triggerring task " + getTaskId() + ", experiment id " + getExperimentId());
+ logger.info("Starting parsing triggering task {}, experiment id {}", getTaskId(), getExperimentId());
ProcessCompletionMessage completionMessage = new ProcessCompletionMessage();
completionMessage.setExperimentId(getExperimentId());
diff --git a/modules/ide-integration/src/main/resources/airavata-server.properties b/modules/ide-integration/src/main/resources/airavata-server.properties
index 560a522b55..67659935dd 100644
--- a/modules/ide-integration/src/main/resources/airavata-server.properties
+++ b/modules/ide-integration/src/main/resources/airavata-server.properties
@@ -274,9 +274,8 @@ email.based.monitor.store.protocol=imaps
email.based.monitor.folder.name=INBOX
email.expiration.minutes=60
email.based.monitoring.period=10000
-
-email.based.monitor.address=airavatatest123@gmail.com
-email.based.monitor.password=airavatatest12345678
+email.based.monitor.address=CHANGE_ME
+email.based.monitor.password=CHANGE_ME
###########################################################################
# ThriftClientPool Configuration