|
|
@ -388,7 +388,7 @@ class Worker(object):
|
|
|
|
if before_state:
|
|
|
|
if before_state:
|
|
|
|
self.set_state(before_state)
|
|
|
|
self.set_state(before_state)
|
|
|
|
|
|
|
|
|
|
|
|
def work(self, burst=False):
|
|
|
|
def work(self, burst=False, logging_level=logging.INFO):
|
|
|
|
"""Starts the work loop.
|
|
|
|
"""Starts the work loop.
|
|
|
|
|
|
|
|
|
|
|
|
Pops and performs all jobs on the current list of queues. When all
|
|
|
|
Pops and performs all jobs on the current list of queues. When all
|
|
|
@ -397,7 +397,7 @@ class Worker(object):
|
|
|
|
|
|
|
|
|
|
|
|
The return value indicates whether any jobs were processed.
|
|
|
|
The return value indicates whether any jobs were processed.
|
|
|
|
"""
|
|
|
|
"""
|
|
|
|
setup_loghandlers()
|
|
|
|
setup_loghandlers(logging_level)
|
|
|
|
self._install_signal_handlers()
|
|
|
|
self._install_signal_handlers()
|
|
|
|
|
|
|
|
|
|
|
|
did_perform_work = False
|
|
|
|
did_perform_work = False
|
|
|
|