Skip to content
Snippets Groups Projects
Commit 94ea0b9d authored by hammonds's avatar hammonds
Browse files

Merge branch 'sftp-bug' into 'master'

fix sftp observer bug for locations that involve host/port

See merge request DM/data-management!3
parents d0f15e0c d2a0e977
No related branches found
No related tags found
No related merge requests found
......@@ -20,14 +20,14 @@ class SftpFileSystemObserverAgent(PollingFileSystemObserverAgent):
def getFiles(self, dataDirectory):
(scheme, host, port, dirPath) = SftpUtility.parseFtpUrl(dataDirectory, defaultHost=self.host, defaultPort=self.port)
remotePrefix = SftpUtility.getRemotePrefix(dataDirectory)
self.logger.debug('Retrieving files from SFTP host: %s, port: %s, directory path: %s, remote prefix: %s' % (host, port, dirPath, remotePrefix))
sftpUtility = SftpUtility(host, port, self.username, self.password, self.privateKey)
self.logger.debug('Retrieving files from SFTP host: %s, port: %s, directory path: %s, remote prefix: %s' % (self.host, self.port, dirPath, remotePrefix))
sftpUtility = SftpUtility(self.host, self.port, self.username, self.password, self.privateKey)
return sftpUtility.getFiles(dirPath, {}, filePathPrefix=remotePrefix)
def getFile(self, filePath):
(scheme, host, port, fPath) = SftpUtility.parseFtpUrl(filePath, defaultHost=self.host, defaultPort=self.port)
remotePrefix = SftpUtility.getRemotePrefix(filePath)
self.logger.debug('Retrieving file from SFTP host: %s, port: %s, directory path: %s, remote prefix: %s' % (host, port, dirPath, remotePrefix))
sftpUtility = SftpUtility(host, port, self.username, self.password, self.privateKey)
self.logger.debug('Retrieving file from SFTP host: %s, port: %s, directory path: %s, remote prefix: %s' % (self.host, self.port, dirPath, remotePrefix))
sftpUtility = SftpUtility(self.host, self.port, self.username, self.password, self.privateKey)
return sftpUtility.getFile(fPath, filePathPrefix=remotePrefix)
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment