You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2015/08/01 02:04:18 UTC
airavata git commit: Added processId to intermediate file transfer
directory name
Repository: airavata
Updated Branches:
refs/heads/master 7ae9cc387 -> 673fbf3b4
Added processId to intermediate file transfer directory name
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/673fbf3b
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/673fbf3b
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/673fbf3b
Branch: refs/heads/master
Commit: 673fbf3b40dda4391a33e7a639d3e13e312c865c
Parents: 7ae9cc3
Author: Shameera Rathanyaka <sh...@gmail.com>
Authored: Fri Jul 31 20:04:12 2015 -0400
Committer: Shameera Rathanyaka <sh...@gmail.com>
Committed: Fri Jul 31 20:04:12 2015 -0400
----------------------------------------------------------------------
.../apache/airavata/gfac/impl/task/AdvancedSCPDataStageTask.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/673fbf3b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/task/AdvancedSCPDataStageTask.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/task/AdvancedSCPDataStageTask.java b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/task/AdvancedSCPDataStageTask.java
index f44621c..29f09e6 100644
--- a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/task/AdvancedSCPDataStageTask.java
+++ b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/task/AdvancedSCPDataStageTask.java
@@ -201,7 +201,8 @@ public class AdvancedSCPDataStageTask implements Task{
return new File(ServerSettings.getOutputLocation() + taskContext.getParentProcessContext()
.getProcessId());
} else {
- return new File(inputPath);
+ inputPath = (inputPath.endsWith(File.separator) ? inputPath : inputPath + File.separator);
+ return new File(inputPath + taskContext.getParentProcessContext().getProcessId());
}
}