Repository: airavata Updated Branches: refs/heads/master b3acdc463 -> 43c0ac50a
added a log to check the orchestrator status consumer events Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/83d1dfd4 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/83d1dfd4 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/83d1dfd4 Branch: refs/heads/master Commit: 83d1dfd4860675dcf2d349dcf3b2053831dbeffc Parents: a2823bc Author: Shameera Rathnayaka Yodage <[email protected]> Authored: Wed Sep 30 10:50:45 2015 -0400 Committer: Shameera Rathnayaka Yodage <[email protected]> Committed: Wed Sep 30 10:50:45 2015 -0400 ---------------------------------------------------------------------- .../airavata/orchestrator/server/OrchestratorServerHandler.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/83d1dfd4/modules/orchestrator/orchestrator-service/src/main/java/org/apache/airavata/orchestrator/server/OrchestratorServerHandler.java ---------------------------------------------------------------------- diff --git a/modules/orchestrator/orchestrator-service/src/main/java/org/apache/airavata/orchestrator/server/OrchestratorServerHandler.java b/modules/orchestrator/orchestrator-service/src/main/java/org/apache/airavata/orchestrator/server/OrchestratorServerHandler.java index 6c04ed7..5862b7a 100644 --- a/modules/orchestrator/orchestrator-service/src/main/java/org/apache/airavata/orchestrator/server/OrchestratorServerHandler.java +++ b/modules/orchestrator/orchestrator-service/src/main/java/org/apache/airavata/orchestrator/server/OrchestratorServerHandler.java @@ -426,6 +426,9 @@ public class OrchestratorServerHandler implements OrchestratorService.Iface { ThriftUtils.createThriftFromBytes(bytes, processStatusChangeEvent); ExperimentStatus status = new ExperimentStatus(); ProcessIdentifier processIdentity = processStatusChangeEvent.getProcessIdentity(); + log.info("expId: {}, processId: {} :- Process status changed event received for status {}", + processIdentity.getExperimentId(), processIdentity.getProcessId(), + processStatusChangeEvent.getState().name()); switch (processStatusChangeEvent.getState()) { // case CREATED: // case VALIDATED: @@ -488,6 +491,7 @@ public class OrchestratorServerHandler implements OrchestratorService.Iface { } break; case CANCELED: + // TODO if experiment have more than one process associated with it, then this should be changed. status.setState(ExperimentState.CANCELED); status.setReason("process cancelled"); break;
