You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2021/09/03 03:28:55 UTC
[airavata-data-lake] branch master updated: Minor logging
improvements
This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata-data-lake.git
The following commit(s) were added to refs/heads/master by this push:
new c514ebd Minor logging improvements
c514ebd is described below
commit c514ebd6a672f5605337bbd6e430ddf70c285304
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Thu Sep 2 23:28:43 2021 -0400
Minor logging improvements
---
.../apache/airavata/drms/api/handlers/ResourceServiceHandler.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/data-resource-management-service/drms-api/src/main/java/org/apache/airavata/drms/api/handlers/ResourceServiceHandler.java b/data-resource-management-service/drms-api/src/main/java/org/apache/airavata/drms/api/handlers/ResourceServiceHandler.java
index e666afd..4ad22f8 100644
--- a/data-resource-management-service/drms-api/src/main/java/org/apache/airavata/drms/api/handlers/ResourceServiceHandler.java
+++ b/data-resource-management-service/drms-api/src/main/java/org/apache/airavata/drms/api/handlers/ResourceServiceHandler.java
@@ -87,6 +87,7 @@ public class ResourceServiceHandler extends ResourceServiceGrpc.ResourceServiceI
" return case when exists((u)<-[:SHARED_WITH]-(r)) OR exists((g)<-[:SHARED_WITH]-(r)) OR " +
"exists((cg)<-[:SHARED_WITH]-(r)) then r else NULL end as value";
+ logger.debug("Fetch resource query {}", query);
List<Record> records = this.neo4JConnector.searchNodes(userProps, query);
try {
@@ -188,6 +189,7 @@ public class ResourceServiceHandler extends ResourceServiceGrpc.ResourceServiceI
" return case when exists((u)<-[:SHARED_WITH]-(r)) OR exists((g)<-[:SHARED_WITH]-(r)) OR " +
"exists((cg)<-[:SHARED_WITH]-(r)) then r else NULL end as value";
+ logger.debug("Create resource query {}", query);
List<Record> records = this.neo4JConnector.searchNodes(exProps, query);
@@ -255,6 +257,8 @@ public class ResourceServiceHandler extends ResourceServiceGrpc.ResourceServiceI
" return distinct cr,crRel, chgr,chgrRel, chcgr,chcgrRel";
}
+ logger.debug("Fetch child query {}", query);
+
List<Record> records = this.neo4JConnector.searchNodes(userProps, query);
try {
@@ -348,6 +352,8 @@ public class ResourceServiceHandler extends ResourceServiceGrpc.ResourceServiceI
"exists((cg)<-[:SHARED_WITH]-(r)) then r else NULL end as value";
+ logger.debug("Update query {}", query);
+
List<Record> records = this.neo4JConnector.searchNodes(exProps, query);
List<GenericResource> genericResourceList = GenericResourceDeserializer.deserializeList(records);
@@ -564,6 +570,8 @@ public class ResourceServiceHandler extends ResourceServiceGrpc.ResourceServiceI
}
}
+ logger.debug("Search query {}", query);
+
List<Record> records = this.neo4JConnector.searchNodes(userProps, query);
List<GenericResource> genericResourceList = GenericResourceDeserializer.deserializeList(records, keyList);