pgq.localconsumer: added file path check on config load

diff --git a/python/pgq/localconsumer.py b/python/pgq/localconsumer.py
index e551536f5ee5f35f4dde829a65bcf35a9a8401c0..45336276913586c69ac685b8bea3652a9a892929 100644 (file)
--- a/python/pgq/localconsumer.py
+++ b/python/pgq/localconsumer.py
@@ -41,6 +41,8 @@ class LocalConsumer(BaseConsumer):
         super(LocalConsumer, self).reload()
 
         self.local_tracking_file = self.cf.getfile('local_tracking_file')
+        if not os.path.exists(os.path.dirname(self.local_tracking_file)):
+            raise skytools.UsageError ("path does not exist: %s" % self.local_tracking_file)
 
     def init_optparse(self, parser = None):
         p = super(LocalConsumer, self).init_optparse(parser)