From 635349b1f0e47ea52734c93c1cff1aada68316c1 Mon Sep 17 00:00:00 2001 From: Sandy Walsh Date: Wed, 7 Nov 2012 10:04:40 -0400 Subject: [PATCH] better logging, stem the worker memory leaks and fix up the start script --- README.md | 2 ++ worker/worker.py | 4 ++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index f15c869..493c775 100644 --- a/README.md +++ b/README.md @@ -76,6 +76,8 @@ You can add as many deployments as you like. #### Starting the Worker +Note: the worker now uses librabbitmq, be sure to install that first. + `./worker/start_workers.py` will spawn a worker.py process for each deployment defined. Each worker will consume from a single Rabbit queue. diff --git a/worker/worker.py b/worker/worker.py index dc4becc..6bf156a 100644 --- a/worker/worker.py +++ b/worker/worker.py @@ -77,7 +77,7 @@ class NovaConsumer(kombu.mixins.ConsumerMixin): if raw: self.processed += 1 - self._check_memory() + self._check_memory() def _check_memory(self): if not self.pmi: @@ -89,7 +89,7 @@ class NovaConsumer(kombu.mixins.ConsumerMixin): check = self.last_time is None if self.last_time: diff = utc - self.last_time - if diff.seconds > 30: + if diff.seconds > 30: check = True if check: self.last_time = utc