(self, args)
Syncer init.
Syncer init.
Syncer init .
def __init__(self, args):
        """Syncer init."""
        skytools.DBScript.__init__(self, 'londiste3', args)
        self.set_single_loop(1)

        # compat names
        self.queue_name = self.cf.get("pgq_queue_name", '')
        self.consumer_name = self.cf.get('pgq_consumer_id', '')

        # good names
        if not self.queue_name:
            self.queue_name = self.cf.get("queue_name")
        if not self.consumer_name:
            self.consumer_name = self.cf.get('consumer_name', self.job_name)

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

        if self.pidfile:
            self.pidfile += ".repair"

        load_handler_modules(self.cf)
def __init__ ( self , args ) : skytools . DBScript . __init__ ( self , 'londiste3' , args ) self . set_single_loop ( 1 ) # compat names self . queue_name = self . cf . get ( "pgq_queue_name" , '' ) self . consumer_name = self . cf . get ( 'pgq_consumer_id' , '' ) # good names if not self . queue_name : self . queue_name = self . cf . get ( "queue_name" ) if not self . consumer_name : self . consumer_name = self . cf . get ( 'consumer_name' , self . job_name ) self . lock_timeout = self . cf . getfloat ( 'lock_timeout' , 10 ) if self . pidfile : self . pidfile += ".repair" load_handler_modules ( self . cf )