Test GroupResult is correctly serialized to save in the result backend
(self, manager)
| 365 | |
| 366 | @flaky |
| 367 | def test_groupresult_serialization(self, manager): |
| 368 | """Test GroupResult is correctly serialized |
| 369 | to save in the result backend""" |
| 370 | try: |
| 371 | manager.app.backend.ensure_chords_allowed() |
| 372 | except NotImplementedError as e: |
| 373 | raise pytest.skip(e.args[0]) |
| 374 | |
| 375 | async_result = build_chain_inside_task.delay() |
| 376 | result = async_result.get() |
| 377 | assert len(result) == 2 |
| 378 | assert isinstance(result[0][1], list) |
| 379 | |
| 380 | @flaky |
| 381 | def test_chain_of_task_a_group_and_a_chord(self, manager): |
nothing calls this directly
no test coverage detected