(self)
| 679 | assert self.mytask.backend.get_status(job.id) == states.REVOKED |
| 680 | |
| 681 | def test_revoked_expires_not_expired(self): |
| 682 | job = self.xRequest( |
| 683 | expires=datetime.now(timezone.utc) + timedelta(days=1), |
| 684 | ) |
| 685 | job.revoked() |
| 686 | assert job.id not in revoked |
| 687 | assert self.mytask.backend.get_status(job.id) != states.REVOKED |
| 688 | |
| 689 | def test_revoked_expires_ignore_result(self): |
| 690 | self.mytask.ignore_result = True |