diff --git a/src/python/dm/common/processing/plugins/fileTransferPlugin.py b/src/python/dm/common/processing/plugins/fileTransferPlugin.py index 2c2228ac20383ffa7429d7ded98183860d44aa0e..cb45db43fbc17f68e113b69edf0f407c295643b9 100755 --- a/src/python/dm/common/processing/plugins/fileTransferPlugin.py +++ b/src/python/dm/common/processing/plugins/fileTransferPlugin.py @@ -38,11 +38,11 @@ class FileTransferPlugin(FileProcessor): def getDestUrl(self, filePath, dataDirectory, storageHost, storageDirectory): # Use relative path with respect to data directory as a source - srcUrl = os.path.relpath(filePath, dataDirectory) + srcDir = os.path.dirname(os.path.relpath(filePath, dataDirectory)) if self.dest: - destUrl = '%s/%s' % (self.dest, srcUrl) + destUrl = '%s/%s/' % (self.dest, srcDir) else: - destUrl = '%s:%s/%s' % (storageHost, storageDirectory, srcUrl) + destUrl = '%s:%s/%s/' % (storageHost, storageDirectory, srcDir) return destUrl def getSrcDirUrl(self, dataDirectory):