From 438340ff9a24e7eddfc4383d34ad44f9d150b214 Mon Sep 17 00:00:00 2001 From: James Date: Wed, 18 Jan 2012 17:52:09 -0500 Subject: [PATCH] CC-3266: Pypo: pypopush will perfom better if it only process the lastest msg from the rabbitMQ queue - done --- python_apps/pypo/pypopush.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/python_apps/pypo/pypopush.py b/python_apps/pypo/pypopush.py index 5293ea284..145f53802 100644 --- a/python_apps/pypo/pypopush.py +++ b/python_apps/pypo/pypopush.py @@ -58,9 +58,12 @@ class PypoPush(Thread): def push(self, export_source): logger = logging.getLogger('push') + # get a new schedule from pypo-fetch if not self.queue.empty(): - scheduled_data = self.queue.get() + # make sure we get the latest schedule + while not self.queue.empty(): + scheduled_data = self.queue.get() logger.debug("Received data from pypo-fetch") self.schedule = scheduled_data['schedule'] self.playlists = scheduled_data['liquidsoap_playlists']