Skip to content
Snippets Groups Projects
Commit b67522a5 authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

Task #11208: from now on, ingest reports dataproducts which failed to...

Task #11208: from now on, ingest reports dataproducts which failed to transfers as failed to MoM (instead of as 'produced', which had it's reasons, but was very illogical
parent 88006af6
No related branches found
No related tags found
No related merge requests found
......@@ -211,13 +211,7 @@ class IngestMomAdapter:
def onJobFailed(self, job_dict):
self.__ingest_notification_listener._logJobNotification('failed ', job_dict, level=logging.WARNING);
if job_dict.get('type','').lower() == 'mom':
# for administrative purposes people want dataproducts
# which did not transfer because the source data was not
# on disk to be registered as JobProduced
mom_status = JobProduced if 'not on disk' in job_dict.get('message','').lower() else JobFailed
self._update_mom_status_if_applicable(job_dict, mom_status)
self._update_mom_status_if_applicable(job_dict, JobFailed)
def onJobRemoved(self, job_dict):
self.__ingest_notification_listener._logJobNotification('removed ', job_dict);
......
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