diff --git a/src/python/dm/common/processing/plugins/fileTransferPlugin.py b/src/python/dm/common/processing/plugins/fileTransferPlugin.py index 6c3d928cc9aed6952c450824b91aed239e277f1f..b1e94f24db7566ca0c51bf693cd0007e5693b942 100755 --- a/src/python/dm/common/processing/plugins/fileTransferPlugin.py +++ b/src/python/dm/common/processing/plugins/fileTransferPlugin.py @@ -22,10 +22,9 @@ class FileTransferPlugin(FileProcessor): def processFile(self, fileInfo): filePath = fileInfo.get('filePath') dataDirectory = fileInfo.get('dataDirectory') - experiment = fileInfo.get('experiment') - storageHost = experiment.get('storageHost') - storageDirectory = experiment.get('storageDirectory') + storageHost = fileInfo.get('storageHost') + storageDirectory = fileInfo.get('storageDirectory') destUrl = self.getDestUrl(filePath, dataDirectory, storageHost, storageDirectory) srcUrl = self.getSrcUrl(filePath, dataDirectory) self.start(srcUrl, destUrl)