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

fix for monitoring after daq stop is issued

parent bafbbdc4
No related branches found
No related tags found
No related merge requests found
......@@ -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))
......
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