Show More
@@ -312,6 +312,20 b' class TestClient(ClusterTestCase):' | |||
|
312 | 312 | r2 = ahr.get(1) |
|
313 | 313 | self.assertFalse(r1 == r2) |
|
314 | 314 | |
|
315 | def test_resubmit_chain(self): | |
|
316 | """resubmit resubmitted tasks""" | |
|
317 | v = self.client.load_balanced_view() | |
|
318 | ar = v.apply_async(lambda x: x, 'x'*1024) | |
|
319 | ar.get() | |
|
320 | self._wait_for_idle() | |
|
321 | ars = [ar] | |
|
322 | ||
|
323 | for i in range(10): | |
|
324 | ar = ars[-1] | |
|
325 | ar2 = self.client.resubmit(ar.msg_ids) | |
|
326 | ||
|
327 | [ ar.get() for ar in ars ] | |
|
328 | ||
|
315 | 329 | def test_resubmit_header(self): |
|
316 | 330 | """resubmit shouldn't clobber the whole header""" |
|
317 | 331 | def f(): |
General Comments 0
You need to be logged in to leave comments.
Login now