Repository: airavata Updated Branches: refs/heads/master 3f0d74a5b -> 75109b640
fail the experiment when storage resources are not set Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/75109b64 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/75109b64 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/75109b64 Branch: refs/heads/master Commit: 75109b640a502e7e804aaef897044ce72f25c617 Parents: 3f0d74a Author: Chathuri Wimalasena <[email protected]> Authored: Thu Dec 17 12:22:30 2015 -0500 Committer: Chathuri Wimalasena <[email protected]> Committed: Thu Dec 17 12:22:30 2015 -0500 ---------------------------------------------------------------------- .../main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/75109b64/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java ---------------------------------------------------------------------- diff --git a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java index f6eda09..8eb77e1 100644 --- a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java +++ b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java @@ -99,8 +99,12 @@ public class GFacEngineImpl implements GFacEngine { if (storagePreference != null) { processContext.setStoragePreference(storagePreference); } else { + // we need to fail the process which will fail the experiment + processContext.setProcessStatus(new ProcessStatus(ProcessState.FAILED)); + GFacUtils.saveAndPublishProcessStatus(processContext); throw new GFacException("expId: " + processModel.getExperimentId() + ", processId: " + processId + ":- Couldn't find storage preference for storage resource id :" + processModel.getStorageResourceId()); + }
