Repository: airavata Updated Branches: refs/heads/master 6c78a0c08 -> 9709417eb
fixing compilation failure Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/9709417e Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/9709417e Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/9709417e Branch: refs/heads/master Commit: 9709417eb9f92c0a7711875d0442a2ae640fff5a Parents: 6c78a0c Author: scnakandala <[email protected]> Authored: Mon Dec 14 11:31:26 2015 -0500 Committer: scnakandala <[email protected]> Committed: Mon Dec 14 11:31:26 2015 -0500 ---------------------------------------------------------------------- .../airavata/gfac/impl/GFacEngineImpl.java | 39 -------------------- 1 file changed, 39 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/9709417e/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 38fcfdf..e2f3ae8 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 @@ -305,45 +305,6 @@ public class GFacEngineImpl implements GFacEngine { } } } - - JobStatus jobStatus = processContext.getJobModel().getJobStatus(); - if (jobStatus != null && (jobStatus.getJobState() == JobState.SUBMITTED - || jobStatus.getJobState() == JobState.QUEUED || jobStatus.getJobState() == JobState.ACTIVE)) { - - List<OutputDataObjectType> processOutputs = processContext.getProcessModel().getProcessOutputs(); - if (processOutputs != null && !processOutputs.isEmpty()){ - for (OutputDataObjectType output : processOutputs){ - try { - if (output.isOutputStreaming()){ - TaskModel streamingTaskModel = new TaskModel(); - streamingTaskModel.setTaskType(TaskTypes.OUTPUT_FETCHING); - streamingTaskModel.setTaskStatus(new TaskStatus(TaskState.CREATED)); - streamingTaskModel.setCreationTime(AiravataUtils.getCurrentTimestamp().getTime()); - streamingTaskModel.setParentProcessId(processContext.getProcessId()); - TaskContext streamingTaskContext = getTaskContext(processContext); - DataStagingTaskModel submodel = new DataStagingTaskModel(); - submodel.setType(DataStageType.OUPUT); - submodel.setProcessOutput(output); - URI source = new URI(processContext.getDataMovementProtocol().name(), - processContext.getComputeResourcePreference().getLoginUserName(), - processContext.getComputeResourceDescription().getHostName(), - 22, - processContext.getWorkingDir() + output.getValue(), null, null); - submodel.setSource(source.getPath()); - submodel.setDestination("dummy://temp/file/location"); - streamingTaskModel.setSubTaskModel(ThriftUtils.serializeThriftObject(submodel)); - String streamTaskId = (String) processContext.getExperimentCatalog() - .add(ExpCatChildDataType.TASK, streamingTaskModel, processContext.getProcessId()); - streamingTaskModel.setTaskId(streamTaskId); - streamingTaskContext.setTaskModel(streamingTaskModel); - executeDataStreaming(streamingTaskContext, processContext.isRecovery()); - } - } catch (URISyntaxException | TException | RegistryException e) { - log.error("Error while streaming output " + output.getValue()); - } - } - } - } break; case MONITORING:
