Show More
@@ -37,6 +37,10 b' def wait(n):' | |||||
37 | time.sleep(n) |
|
37 | time.sleep(n) | |
38 | return n |
|
38 | return n | |
39 |
|
39 | |||
|
40 | @pmod.interactive | |||
|
41 | def func(x): | |||
|
42 | return x*x | |||
|
43 | ||||
40 | mixed = map(str, range(10)) |
|
44 | mixed = map(str, range(10)) | |
41 | completed = map(str, range(0,10,2)) |
|
45 | completed = map(str, range(0,10,2)) | |
42 | failed = map(str, range(1,10,2)) |
|
46 | failed = map(str, range(1,10,2)) | |
@@ -104,3 +108,29 b' class DependencyTest(ClusterTestCase):' | |||||
104 | dep.all=False |
|
108 | dep.all=False | |
105 | self.assertUnmet(dep) |
|
109 | self.assertUnmet(dep) | |
106 | self.assertUnreachable(dep) |
|
110 | self.assertUnreachable(dep) | |
|
111 | ||||
|
112 | def test_require_function(self): | |||
|
113 | ||||
|
114 | @pmod.interactive | |||
|
115 | def bar(a): | |||
|
116 | return func(a) | |||
|
117 | ||||
|
118 | @pmod.require(func) | |||
|
119 | @pmod.interactive | |||
|
120 | def bar2(a): | |||
|
121 | return func(a) | |||
|
122 | ||||
|
123 | self.client[:].clear() | |||
|
124 | self.assertRaisesRemote(NameError, self.view.apply_sync, bar, 5) | |||
|
125 | ar = self.view.apply_async(bar2, 5) | |||
|
126 | self.assertEqual(ar.get(5), func(5)) | |||
|
127 | ||||
|
128 | def test_require_object(self): | |||
|
129 | ||||
|
130 | @pmod.require(foo=func) | |||
|
131 | @pmod.interactive | |||
|
132 | def bar(a): | |||
|
133 | return foo(a) | |||
|
134 | ||||
|
135 | ar = self.view.apply_async(bar, 5) | |||
|
136 | self.assertEqual(ar.get(5), func(5)) |
General Comments 0
You need to be logged in to leave comments.
Login now