This is an automated email from the ASF dual-hosted git repository. yasith pushed a commit to branch cybershuttle-dev in repository https://gitbox.apache.org/repos/asf/airavata.git
commit ad2d1c367f4551ac896b4d97f3360fb23ab4ce98 Author: yasithdev <[email protected]> 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 protected] -email.based.monitor.password=airavatatest12345678 +email.based.monitor.address=CHANGE_ME +email.based.monitor.password=CHANGE_ME ########################################################################### # ThriftClientPool Configuration
