This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/airavata.git.
from 42be237 Merge branch 'ansible-upgrade' into develop
add c905ef5 Optimizing task retry logic
add 6c6cfdc Fixing NPE when fetching the curator client
add b4c3bab Adding missing emails to email monitor
add c1b12e5 Adding missing path separator for retry counter
add b64f33b implementation of DataParsingTask, CatalogEntry, and
CatalogUtil
add 1447321 Catalog Graph implementation with Dijkstra shortest path
algorithm
add e0486d4 Parser workflow manager and parser request implementation
add 4ff6b34 distribution of parser workflow manager
add 9b40364 changed the way of getting shortest path entries considering
application and multiple operations
add 8a4eb0a avoid source vertex self loops
add 2af9090 Merge pull request #206 from Lahiru-J/staging
new 3e77e16 Merge branch 'staging' into develop
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
modules/airavata-helix/helix-distribution/pom.xml | 16 ++
...bin-assembly.xml => parser-wm-bin-assembly.xml} | 7 +-
.../bin/parser-wm-daemon.sh} | 8 +-
.../bin/pre-wm.sh => parser-wm/bin/parser-wm.sh} | 6 +-
.../resources/{pre-wm => parser-wm}/bin/setenv.sh | 4 +-
.../conf/airavata-server.properties | 15 +-
.../src/main/resources/parser-wm/conf}/logback.xml | 0
.../helix/impl/participant/GlobalParticipant.java | 3 +-
.../airavata/helix/impl/task/AiravataTask.java | 83 ++++---
.../airavata/helix/impl/task/env/EnvSetupTask.java | 2 +-
.../helix/impl/task/parsing/CatalogEntry.java | 249 ++++++++++++++++++++
.../helix/impl/task/parsing/CatalogGraph.java | 78 +++++++
.../helix/impl/task/parsing/CatalogUtil.java | 105 +++++++++
.../helix/impl/task/parsing/DataParsingTask.java | 206 ++++++++++++++++
.../helix/impl/task/parsing/ParserRequest.java | 84 +++++++
.../parsing/shortestpath/DijkstraShortestPath.java | 258 +++++++++++++++++++++
.../task/parsing/shortestpath/DirectedGraph.java | 73 ++++++
.../helix/impl/task/parsing/shortestpath/Edge.java | 64 +++++
.../impl/task/parsing/shortestpath/Vertex.java} | 61 ++---
.../helix/impl/task/staging/DataStagingTask.java | 8 +-
.../impl/task/staging/InputDataStagingTask.java | 6 +-
.../impl/task/staging/OutputDataStagingTask.java | 2 +-
.../helix/impl/workflow/ParserWorkflowManager.java | 121 ++++++++++
.../src/main/resources/airavata-server.properties | 8 +-
.../apache/airavata/helix/core/AbstractTask.java | 9 +
.../airavata/helix/core/util/MonitoringUtil.java | 25 +-
.../resources/email-monitor/conf/email-config.yaml | 1 +
27 files changed, 1411 insertions(+), 91 deletions(-)
copy
modules/airavata-helix/helix-distribution/src/main/assembly/{controller-bin-assembly.xml
=> parser-wm-bin-assembly.xml} (93%)
copy
modules/airavata-helix/helix-distribution/src/main/resources/{controller/bin/controller-daemon.sh
=> parser-wm/bin/parser-wm-daemon.sh} (90%)
copy
modules/airavata-helix/helix-distribution/src/main/resources/{pre-wm/bin/pre-wm.sh
=> parser-wm/bin/parser-wm.sh} (90%)
copy modules/airavata-helix/helix-distribution/src/main/resources/{pre-wm =>
parser-wm}/bin/setenv.sh (99%)
mode change 100755 => 100644
copy modules/airavata-helix/helix-distribution/src/main/resources/{pre-wm =>
parser-wm}/conf/airavata-server.properties (83%)
copy modules/{job-monitor/real-time-monitor/src/main/resources =>
airavata-helix/helix-distribution/src/main/resources/parser-wm/conf}/logback.xml
(100%)
create mode 100644
modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/CatalogEntry.java
create mode 100644
modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/CatalogGraph.java
create mode 100644
modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/CatalogUtil.java
create mode 100644
modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/DataParsingTask.java
create mode 100644
modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/ParserRequest.java
create mode 100644
modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/shortestpath/DijkstraShortestPath.java
create mode 100644
modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/shortestpath/DirectedGraph.java
create mode 100644
modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/shortestpath/Edge.java
copy
modules/{registry/registry-core/src/main/java/org/apache/airavata/registry/core/workflow/catalog/model/Edge_PK.java
=>
airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/parsing/shortestpath/Vertex.java}
(51%)
create mode 100644
modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/ParserWorkflowManager.java
