@@ -196,7 +196,8 @@ def __init__(self, pool_size=5, queues=[], server='localhost:6379', password=Non
196
196
#self._workers = list()
197
197
198
198
def setup_resq (self ):
199
- self .logger .info ('Connecting to redis server - %s' % self .server )
199
+ if hasattr (self ,'logger' ):
200
+ self .logger .info ('Connecting to redis server - %s' % self .server )
200
201
if isinstance (self .server ,basestring ):
201
202
self .resq = ResQ (server = self .server , password = self .password )
202
203
elif isinstance (self .server , ResQ ):
@@ -297,19 +298,24 @@ def _remove_minion(self, pid=None):
297
298
return m
298
299
299
300
def unregister_khan (self ):
300
- self .logger .debug ('unregistering khan' )
301
+ if hasattr (self ,'logger' ):
302
+ self .logger .debug ('unregistering khan' )
301
303
self .resq .redis .srem ('resque:khans' ,str (self ))
302
304
self .started = None
303
305
304
306
def setup_minions (self ):
305
307
for i in range (self .pool_size ):
306
308
self ._add_minion ()
307
309
310
+ def _setup_logging (self ):
311
+ self .logger = setup_logging ('khan' , self .logging_level , self .log_file )
312
+
308
313
def work (self , interval = 2 ):
309
314
setproctitle ('pyres_manager: Starting' )
310
315
self .startup ()
311
316
self .setup_minions ()
312
- self .logger = setup_logging ('khan' , self .logging_level , self .log_file )
317
+ #self.logger = setup_logging('khan', self.logging_level, self.log_file)
318
+ self ._setup_logging ()
313
319
self .logger .info ('Running as pid: %s' % self .pid )
314
320
self .logger .info ('Added %s child processes' % self .pool_size )
315
321
self .logger .info ('Setting up pyres connection' )
0 commit comments