(self, args)
Londiste setup init.
Londiste setup init.
Londiste setup init .
def __init__(self, args):
        """Londiste setup init."""
        CascadeAdmin.__init__(self, 'londiste3', 'db', args, worker_setup = True)

        # compat
        self.queue_name = self.cf.get('pgq_queue_name', '')
        # real
        if not self.queue_name:
            self.queue_name = self.cf.get('queue_name')

        self.set_name = self.queue_name

        self.lock_timeout = self.cf.getfloat('lock_timeout', 10)

        londiste.handler.load_handler_modules(self.cf)
def __init__ ( self , args ) : CascadeAdmin . __init__ ( self , 'londiste3' , 'db' , args , worker_setup = True ) # compat self . queue_name = self . cf . get ( 'pgq_queue_name' , '' ) # real if not self . queue_name : self . queue_name = self . cf . get ( 'queue_name' ) self . set_name = self . queue_name self . lock_timeout = self . cf . getfloat ( 'lock_timeout' , 10 ) londiste . handler . load_handler_modules ( self . cf )