You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2015/12/14 17:31:31 UTC
airavata git commit: fixing compilation failure
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 <su...@gmail.com>
Authored: Mon Dec 14 11:31:26 2015 -0500
Committer: scnakandala <su...@gmail.com>
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: