Skip to content
Snippets Groups Projects
Commit fbbd893c authored by sveseli's avatar sveseli
Browse files

merged updates from 0.7 release

parents 3f5fcea5 b44ce713
No related branches found
No related tags found
No related merge requests found
Release 0.7 ()
Release 0.7 (12/08/2015)
=============================
- Introduced framework and user interfaces for tracking progress of file
......
__version__ = "0.6 (2015.11.09)"
__version__ = "0.7 (2015.12.08)"
......@@ -20,11 +20,10 @@ class RsyncWithChecksumAndDeleteFileTransferPlugin(FileTransferPlugin):
def processFile(self, fileInfo):
filePath = fileInfo.get('filePath')
dataDirectory = fileInfo.get('dataDirectory')
experiment = fileInfo.get('experiment')
experimentName = experiment.get('name')
experimentFilePath = fileInfo.get('experimentFilePath')
storageHost = experiment.get('storageHost')
storageDirectory = experiment.get('storageDirectory')
experimentFilePath = fileInfo.get('experimentFilePath')
experimentName = fileInfo.get('experimentName')
storageHost = fileInfo.get('storageHost')
storageDirectory = fileInfo.get('storageDirectory')
destUrl = self.getDestUrl(filePath, dataDirectory, storageHost, storageDirectory)
# Use relative path with respect to data directory as a source
os.chdir(dataDirectory)
......
......@@ -42,9 +42,9 @@ class DmFileSystemEventHandler(FileSystemEventHandler):
def processEvent(self, event):
if event.is_directory:
self.logger.debug('Processing directory event: %s , src path: %s , latest files: %s' % (event.__dict__, event.src_path, files))
try:
files = glob.glob(os.path.join(event.src_path,'*.*'))
self.logger.debug('Processing directory event: %s , src path: %s , latest files: %s' % (event.__dict__, event.src_path, files))
if len(files) > 0:
filePath = max(files, key=os.path.getctime)
self.logger.debug('Latest file: %s' % (filePath))
......
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