Sink log output in unit tests
This commit is contained in:
@@ -33,14 +33,15 @@ import unittest
|
|||||||
import Queue
|
import Queue
|
||||||
from mumo_manager import MumoManager, MumoManagerRemote
|
from mumo_manager import MumoManager, MumoManagerRemote
|
||||||
from mumo_module import MumoModule
|
from mumo_module import MumoModule
|
||||||
from logging import basicConfig, ERROR
|
from logging import basicConfig, ERROR, getLogger
|
||||||
import logging
|
import logging
|
||||||
from threading import Event
|
from threading import Event
|
||||||
|
|
||||||
|
|
||||||
class MumoManagerTest(unittest.TestCase):
|
class MumoManagerTest(unittest.TestCase):
|
||||||
def setUp(self):
|
def setUp(self):
|
||||||
basicConfig(level = ERROR)
|
l = getLogger("MumoManager")
|
||||||
|
l.disabled = True
|
||||||
|
|
||||||
class MyModule(MumoModule):
|
class MyModule(MumoModule):
|
||||||
def __init__(self, name, manager, configuration = None):
|
def __init__(self, name, manager, configuration = None):
|
||||||
|
|||||||
@@ -30,11 +30,14 @@
|
|||||||
# SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
# SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||||
|
|
||||||
import unittest
|
import unittest
|
||||||
|
|
||||||
import worker
|
import worker
|
||||||
from worker import Worker, local_thread, local_thread_blocking
|
from worker import Worker, local_thread, local_thread_blocking
|
||||||
from Queue import Queue
|
from Queue import Queue
|
||||||
from logging.handlers import BufferingHandler
|
from logging.handlers import BufferingHandler
|
||||||
from logging import ERROR
|
from logging import ERROR
|
||||||
|
import logging
|
||||||
|
|
||||||
from threading import Event
|
from threading import Event
|
||||||
from time import sleep
|
from time import sleep
|
||||||
|
|
||||||
@@ -93,13 +96,20 @@ class WorkerTest(unittest.TestCase):
|
|||||||
|
|
||||||
q = Queue()
|
q = Queue()
|
||||||
self.q = q
|
self.q = q
|
||||||
self.w = ATestWorker("Test", q)
|
|
||||||
l = self.w.log()
|
NAME = "Test"
|
||||||
|
l = logging.getLogger(NAME)
|
||||||
|
|
||||||
|
self.w = ATestWorker(NAME, q)
|
||||||
|
self.assertEqual(self.w.log(), l)
|
||||||
|
|
||||||
|
l.propagate = 0
|
||||||
l.addHandler(self.buha)
|
l.addHandler(self.buha)
|
||||||
assert(self.w.started == False)
|
|
||||||
|
self.assertFalse(self.w.started)
|
||||||
self.w.start()
|
self.w.start()
|
||||||
sleep(0.05)
|
sleep(0.05)
|
||||||
assert(self.w.started == True)
|
self.assertTrue(self.w.started)
|
||||||
|
|
||||||
def testName(self):
|
def testName(self):
|
||||||
assert(self.w.name() == "Test")
|
assert(self.w.name() == "Test")
|
||||||
|
|||||||
Reference in New Issue
Block a user