diff --git a/LTA/LTAIngest/LTAIngestServer/LTAIngestAdminServer/lib/ingestmomadapter.py b/LTA/LTAIngest/LTAIngestServer/LTAIngestAdminServer/lib/ingestmomadapter.py index ae386df2a7d5e21821bbaa67905ee8df9aa7b432..c3f960515bfc98f8482808627afa70147205c848 100644 --- a/LTA/LTAIngest/LTAIngestServer/LTAIngestAdminServer/lib/ingestmomadapter.py +++ b/LTA/LTAIngest/LTAIngestServer/LTAIngestAdminServer/lib/ingestmomadapter.py @@ -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);