(self)
| 743 | job.execute() |
| 744 | |
| 745 | def test_execute_acks_late(self): |
| 746 | self.mytask_raising.acks_late = True |
| 747 | job = self.xRequest( |
| 748 | name=self.mytask_raising.name, |
| 749 | kwargs={}, |
| 750 | ) |
| 751 | job.execute() |
| 752 | assert job.acknowledged |
| 753 | job.execute() |
| 754 | |
| 755 | def test_execute_using_pool_does_not_execute_revoked(self): |
| 756 | job = self.xRequest() |