(self, task_class)
| 632 | self.put(self._task_key(task_class, 'rt'), (revoke_until, revoke_once)) |
| 633 | |
| 634 | def restore_all(self, task_class): |
| 635 | if isinstance(task_class, TaskWrapper): |
| 636 | task_class = task_class.task_class |
| 637 | return self.delete(self._task_key(task_class, 'rt')) |
| 638 | |
| 639 | def revoke(self, task, revoke_until=None, revoke_once=False): |
| 640 | if revoke_until is not None: |
no test coverage detected