diff --git a/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py b/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py
index 99ac03fe682c32f630ce96348a4ba22ce84c9a22..d4ac844acc011d96c215a90018bad1e0ed643399 100755
--- a/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py
+++ b/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py
@@ -44,11 +44,11 @@ class GridftpFileTransferPlugin(FileTransferPlugin):
         storageDirectory = uploadInfo['storageDirectory']
         dataDirectory = uploadInfo['dataDirectory']
         self.logger.debug('Upload info: %s', uploadInfo)
-        #(scheme, host, port, dirPath) = FtpUtility.parseFtpUrl(storageUrl, defaultPort=self.DEFAULT_PORT)
+        (scheme, host, port, storageDirPath) = FtpUtility.parseFtpUrl(storageUrl)
         ftpUtility = SftpUtility(storageHost)
         self.logger.debug("STORAGE DIR: %s", storageDirectory)
         self.logger.debug("STORAGE HOST: %s", storageHost)
-        storageFilePathsDict = ftpUtility.getFiles(storageDirectory, {}, dataDirectory)
+        storageFilePathsDict = ftpUtility.getFiles(storageDirectory, {}, storageDirPath)
         self.logger.debug("STORAGE PATHS: %s", storageFilePathsDict)
         self.logger.debug("ORIG PATHS: %s", filePathsDict)
         pluginFilePathsDict = {}