(self, manager, subtests)
| 1475 | redis_connection.delete(redis_key) |
| 1476 | |
| 1477 | def test_group_children_with_errbacks(self, manager, subtests): |
| 1478 | if not manager.app.conf.result_backend.startswith("redis"): |
| 1479 | raise pytest.skip("Requires redis result backend.") |
| 1480 | redis_connection = get_redis_connection() |
| 1481 | |
| 1482 | redis_key = str(uuid.uuid4()) |
| 1483 | errback = redis_count.si(redis_key=redis_key) |
| 1484 | |
| 1485 | child_task_count = 42 |
| 1486 | child_sig = fail.si() |
| 1487 | child_sig.link_error(errback) |
| 1488 | group_sig = group(child_sig for _ in range(child_task_count)) |
| 1489 | |
| 1490 | redis_connection.delete(redis_key) |
| 1491 | with subtests.test(msg="Chain fails due to a child task dying"): |
| 1492 | res_obj = group_sig() |
| 1493 | with pytest.raises(ExpectedException): |
| 1494 | res_obj.get(timeout=TIMEOUT) |
| 1495 | with subtests.test(msg="Chain child task errbacks are called"): |
| 1496 | await_redis_count(child_task_count, redis_key=redis_key) |
| 1497 | redis_connection.delete(redis_key) |
| 1498 | |
| 1499 | def test_group_with_callback_child_replaced(self, manager, subtests): |
| 1500 | if not manager.app.conf.result_backend.startswith("redis"): |
nothing calls this directly
no test coverage detected