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

mark DAQ as failed rather than finalizing if all files have not been processed

parent 1b660927
No related branches found
No related tags found
No related merge requests found
...@@ -114,11 +114,12 @@ class DaqInfo(DmObject): ...@@ -114,11 +114,12 @@ class DaqInfo(DmObject):
self['percentageProcessingErrors'] = '%.2f' % percentageProcessingErrors self['percentageProcessingErrors'] = '%.2f' % percentageProcessingErrors
if self.get('endTime'): if self.get('endTime'):
daqStatus = dmProcessingStatus.DM_PROCESSING_STATUS_FINALIZING
if nCompletedFiles >= nFiles: if nCompletedFiles >= nFiles:
daqStatus = dmProcessingStatus.DM_PROCESSING_STATUS_DONE daqStatus = dmProcessingStatus.DM_PROCESSING_STATUS_DONE
if nProcessingErrors: if nProcessingErrors:
daqStatus = dmProcessingStatus.DM_PROCESSING_STATUS_FAILED daqStatus = dmProcessingStatus.DM_PROCESSING_STATUS_FAILED
else:
daqStatus = dmProcessingStatus.DM_PROCESSING_STATUS_FAILED
lastFileProcessingErrorTime = self.get('lastFileProcessingErrorTime') lastFileProcessingErrorTime = self.get('lastFileProcessingErrorTime')
lastFileProcessedTime = self.get('lastFileProcessedTime') lastFileProcessedTime = self.get('lastFileProcessedTime')
endTime = lastFileProcessedTime endTime = lastFileProcessedTime
......
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