Show More
@@ -93,6 +93,8 class ClusterTestCase(BaseZMQTestCase): | |||
|
93 | 93 | def setUp(self): |
|
94 | 94 | BaseZMQTestCase.setUp(self) |
|
95 | 95 | self.client = self.connect_client() |
|
96 | # start every test with clean engine namespaces: | |
|
97 | self.client.clear(block=True) | |
|
96 | 98 | self.base_engine_count=len(self.client.ids) |
|
97 | 99 | self.engines=[] |
|
98 | 100 |
@@ -85,8 +85,8 class TestClient(ClusterTestCase): | |||
|
85 | 85 | v.push(dict(a=5)) |
|
86 | 86 | v.pull('a') |
|
87 | 87 | id0 = self.client.ids[-1] |
|
88 | self.client.clear(targets=id0) | |
|
89 |
self.client[:-1]. |
|
|
88 | self.client.clear(targets=id0, block=True) | |
|
89 | a = self.client[:-1].get('a') | |
|
90 | 90 | self.assertRaisesRemote(NameError, self.client[id0].get, 'a') |
|
91 | 91 | self.client.clear(block=True) |
|
92 | 92 | for i in self.client.ids: |
@@ -298,7 +298,8 class TestView(ClusterTestCase): | |||
|
298 | 298 | def findall(pat, s): |
|
299 | 299 | # this globals() step isn't necessary in real code |
|
300 | 300 | # only to prevent a closure in the test |
|
301 |
re |
|
|
301 | re = globals()['re'] | |
|
302 | return re.findall(pat, s) | |
|
302 | 303 | |
|
303 | 304 | self.assertEquals(view.apply_sync(findall, '\w+', 'hello world'), 'hello world'.split()) |
|
304 | 305 |
General Comments 0
You need to be logged in to leave comments.
Login now