Show More
@@ -312,6 +312,20 b' class TestClient(ClusterTestCase):' | |||||
312 | r2 = ahr.get(1) |
|
312 | r2 = ahr.get(1) | |
313 | self.assertFalse(r1 == r2) |
|
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 | def test_resubmit_header(self): |
|
329 | def test_resubmit_header(self): | |
316 | """resubmit shouldn't clobber the whole header""" |
|
330 | """resubmit shouldn't clobber the whole header""" | |
317 | def f(): |
|
331 | def f(): |
General Comments 0
You need to be logged in to leave comments.
Login now