From e4a756075a14582b653c3f7abed7ef7b2f3fc2d5 Mon Sep 17 00:00:00 2001 From: Rudi Grinberg Date: Mon, 13 Aug 2012 12:52:36 -0400 Subject: [PATCH] cc-4105: removed workarond for old bug. bug was: events not being removed from contractor --- python_apps/media-monitor2/media/monitor/events.py | 3 ++- python_apps/media-monitor2/media/monitor/watchersyncer.py | 8 +++----- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/python_apps/media-monitor2/media/monitor/events.py b/python_apps/media-monitor2/media/monitor/events.py index 1c4735d2b..d6d320d77 100644 --- a/python_apps/media-monitor2/media/monitor/events.py +++ b/python_apps/media-monitor2/media/monitor/events.py @@ -82,8 +82,9 @@ class BaseEvent(Loggable): # pack will only throw an exception if it processes one file but this # is a little bit hacky try: - return self.pack() + ret = self.pack() self._pack_hook() + return ret except BadSongFile as e: return [e] # nothing to see here, please move along diff --git a/python_apps/media-monitor2/media/monitor/watchersyncer.py b/python_apps/media-monitor2/media/monitor/watchersyncer.py index f7497b9b4..fe6e8a473 100644 --- a/python_apps/media-monitor2/media/monitor/watchersyncer.py +++ b/python_apps/media-monitor2/media/monitor/watchersyncer.py @@ -3,7 +3,6 @@ import threading import time import copy import traceback -from itertools import ifilter from media.monitor.handler import ReportHandler from media.monitor.log import Loggable @@ -34,8 +33,7 @@ class RequestSync(threading.Thread,Loggable): # TODO : recorded shows aren't flagged right # Is this retry shit even necessary? Consider getting rid of this. packed_requests = [] - for request_event in ifilter(lambda x: not x.morph_target(), - self.requests): + for request_event in self.requests: try: for request in request_event.safe_pack(): if isinstance(request, BadSongFile): @@ -123,8 +121,8 @@ class WatchSyncer(ReportHandler,Loggable): try: # If there is a strange bug anywhere in the code the next line # should be a suspect - self.contractor.register( event ) - self.push_queue( event ) + if self.contractor.register( event ): + self.push_queue( event ) except BadSongFile as e: self.fatal_exception("Received bas song file '%s'" % e.path, e) except Exception as e: