diff --git a/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py b/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py
index d4ac844acc011d96c215a90018bad1e0ed643399..11942b9cb5ce3ebd92d37872145ebee1f09a5c9d 100755
--- a/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py
+++ b/src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py
@@ -44,7 +44,8 @@ class GridftpFileTransferPlugin(FileTransferPlugin):
         storageDirectory = uploadInfo['storageDirectory']
         dataDirectory = uploadInfo['dataDirectory']
         self.logger.debug('Upload info: %s', uploadInfo)
-        (scheme, host, port, storageDirPath) = FtpUtility.parseFtpUrl(storageUrl)
+        # Storage directory may contain host/port
+        (scheme, host, port, storageDirPath) = FtpUtility.parseFtpUrl(storageDirectory)
         ftpUtility = SftpUtility(storageHost)
         self.logger.debug("STORAGE DIR: %s", storageDirectory)
         self.logger.debug("STORAGE HOST: %s", storageHost)