diff --git a/src/python/dm/common/processing/fileProcessingThread.py b/src/python/dm/common/processing/fileProcessingThread.py index bb1a1586be9df1583e2738f6f52b65a4b3961cad..0e9b8a25a7b28040cbb01ef302721d22ce8060a5 100755 --- a/src/python/dm/common/processing/fileProcessingThread.py +++ b/src/python/dm/common/processing/fileProcessingThread.py @@ -36,6 +36,7 @@ class FileProcessingThread(threading.Thread): self.logger.debug('File %s processing is cancelled' % (filePath)) endProcessingTime = time.time() statusMonitor.fileProcessingCancelled(filePath, endProcessingTime) + statusMonitor.updateStatus() return self.logger.debug('Starting to process file %s' % filePath) startProcessingTime = fileInfo.get('startProcessingTime', time.time()) @@ -67,6 +68,7 @@ class FileProcessingThread(threading.Thread): endProcessingTime = time.time() if statusMonitor: statusMonitor.fileProcessed(filePath, endProcessingTime) + statusMonitor.updateStatus() except Exception, ex: self.logger.exception(ex) processingError = '%s processing error: %s' % (processorName, str(ex))