[airavata] branch develop updated: Adding debug logs

[isjarana]

This is an automated email from the ASF dual-hosted git repository.

isjarana pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/airavata.git


The following commit(s) were added to refs/heads/develop by this push:
     new 6b2f7d7759 Adding debug logs
     new aa2e3430c0 Merge pull request #335 from isururanawaka/metaschedular
6b2f7d7759 is described below

commit 6b2f7d7759abb9aa0e7dd492594d87fada163872
Author: Isuru Ranawaka <irjan...@gmail.com>
AuthorDate: Mon Nov 21 09:29:58 2022 -0500

    Adding debug logs
---
 .../airavata/compute/resource/monitoring/job/MonitoringJob.java      | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/modules/computer-resource-monitoring-service/src/main/java/org/apache/airavata/compute/resource/monitoring/job/MonitoringJob.java
 
b/modules/computer-resource-monitoring-service/src/main/java/org/apache/airavata/compute/resource/monitoring/job/MonitoringJob.java
index fbbfa4e969..c4f424f5f1 100644
--- 
a/modules/computer-resource-monitoring-service/src/main/java/org/apache/airavata/compute/resource/monitoring/job/MonitoringJob.java
+++ 
b/modules/computer-resource-monitoring-service/src/main/java/org/apache/airavata/compute/resource/monitoring/job/MonitoringJob.java
@@ -70,7 +70,7 @@ public class MonitoringJob extends ComputeResourceMonitor 
implements Job {
                     .subList(startIndex, endIndex);
 
             for (GroupComputeResourcePreference computeResourcePreference : 
computeResourcePreferences) {
-                LOGGER.info("updating 
GRP###########",computeResourcePreference.getComputeResourceId());
+                LOGGER.info("updating GRP########### 
PRID:"+computeResourcePreference.getComputeResourceId()+" name 
"+computeResourcePreference.);
                 updateComputeResource(client, adaptorSupport, 
metaSchedulerGateway, username, metaSchedulerGRP, computeResourcePreference);
             }
         } catch (Exception ex) {
@@ -109,6 +109,8 @@ public class MonitoringJob extends ComputeResourceMonitor 
implements Job {
                 baseCommand = 
resourceJobManager.getJobManagerCommands().get(JobManagerCommand.SHOW_CLUSTER_INFO);
             }
 
+
+
             String finalCommand = baseCommand + "-p" + 
computeResourcePreference.getPreferredBatchQueue();
 
             String computeResourceToken = getComputeResourceCredentialToken(
@@ -167,6 +169,7 @@ public class MonitoringJob extends ComputeResourceMonitor 
implements Job {
             QueueStatusModel queueStatusModel = new QueueStatusModel();
             queueStatusModel.setHostName(comResourceDes.getHostName());
             
queueStatusModel.setQueueName(computeResourcePreference.getPreferredBatchQueue());
+            LOGGER.info("Storing hostname "+comResourceDes.getHostName()+" 
batch queue "+computeResourcePreference.getPreferredBatchQueue());
             queueStatusModel.setQueueUp(queueStatus);
             queueStatusModel.setRunningJobs(runningJobs);
             queueStatusModel.setQueuedJobs(pendingJobs);