diff --git a/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py b/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py index 3b5e84bfa3a5b1be00774cd04f192f4b32307bce..cc9004dd9ba7b762ed7bbcf226b9582ce9eaee8f 100755 --- a/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py +++ b/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py @@ -85,7 +85,7 @@ class GridftpFileTransferPlugin(FileTransferPlugin): # Calculate checksum (scheme, host, port, dirPath) = FtpUtility.parseFtpUrl(dataDirectory, defaultPort=self.DEFAULT_PORT) ftpUtility = FtpUtility(host, port) - ftpUtility.statFile(filePath, fileInfo) + ftpUtility.statFile(filePath, fileInfo) if self.localMd5Sum: ftpUtility.getMd5Sum(filePath, fileInfo) @@ -110,9 +110,9 @@ class GridftpFileTransferPlugin(FileTransferPlugin): self.logger.debug('Checksum test passed for file %s' % filePath) # Remove file - if self.deleteOriginal: - self.logger.debug('Deleting file %s' % filePath) - OsUtility.removeFile(srcUrl) + #if self.deleteOriginal: + # self.logger.debug('Deleting file %s' % filePath) + # OsUtility.removeFile(srcUrl) ####################################################################### # Testing. diff --git a/src/python/dm/common/processing/plugins/rsyncFileTransferPlugin.py b/src/python/dm/common/processing/plugins/rsyncFileTransferPlugin.py index 525ad75214008ebe7ee501582aa44b3495441f89..aa5c4d31bcbae30c5b27040fcaf8c77aeb8cab8c 100755 --- a/src/python/dm/common/processing/plugins/rsyncFileTransferPlugin.py +++ b/src/python/dm/common/processing/plugins/rsyncFileTransferPlugin.py @@ -54,7 +54,7 @@ class RsyncFileTransferPlugin(FileTransferPlugin): srcUrl = self.getSrcUrl(filePath, dataDirectory) # Calculate checksum - FileUtility.statFile(filePath, fileInfo) + FileUtility.statFile(filePath, fileInfo) if self.localMd5Sum: FileUtility.statFile(filePath, fileInfo) FileUtility.getMd5Sum(filePath, fileInfo)