From bafbbdc4d759b65ef51156c0ece30f59ac57f61e Mon Sep 17 00:00:00 2001
From: Sinisa Veseli <sveseli@aps.anl.gov>
Date: Tue, 12 Apr 2016 21:29:03 +0000
Subject: [PATCH] fix for monitoring after daq stop is issued
---
src/python/dm/common/processing/fileProcessingThread.py | 1 +
.../dm/daq_web_service/service/impl/fileSystemObserver.py | 6 ++++--
2 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/src/python/dm/common/processing/fileProcessingThread.py b/src/python/dm/common/processing/fileProcessingThread.py
index f535b56f..bb1a1586 100755
--- a/src/python/dm/common/processing/fileProcessingThread.py
+++ b/src/python/dm/common/processing/fileProcessingThread.py
@@ -84,6 +84,7 @@ class FileProcessingThread(threading.Thread):
endProcessingTime = time.time()
if statusMonitor:
statusMonitor.fileProcessingError(filePath, processingError, endProcessingTime)
+ statusMonitor.updateStatus()
self.logger.debug('No more %s retries left for file %s, remaining plugins will not process it' % (processorName, filePath))
return
else:
diff --git a/src/python/dm/daq_web_service/service/impl/fileSystemObserver.py b/src/python/dm/daq_web_service/service/impl/fileSystemObserver.py
index b3900e5a..74ef566b 100755
--- a/src/python/dm/daq_web_service/service/impl/fileSystemObserver.py
+++ b/src/python/dm/daq_web_service/service/impl/fileSystemObserver.py
@@ -108,9 +108,11 @@ class FileSystemObserver(threading.Thread,Singleton):
observedFile = ObservedFile(filePath=filePath, dataDirectory=dataDirectory, experiment=experiment)
observedFile['daqInfo'] = daqInfo.toDictWithOriginalKeys()
observedFile['statusMonitor'] = daqInfo
+ self.observedFileMap[filePath] = observedFile
+ self.logger.debug('New observed file: %s', filePath)
+ else:
+ self.logger.debug('Observed file updated: %s', filePath)
observedFile.setLastUpdateTimeToNow()
- self.observedFileMap[filePath] = observedFile
- self.logger.debug('Observed file updated: %s', filePath)
@ThreadingUtility.synchronize
def checkObservedFilesForProcessing(self):
--
GitLab