(self, task_class, key)
| 622 | } |
| 623 | |
| 624 | def _task_key(self, task_class, key): |
| 625 | return ':'.join((key, self._registry.task_to_string(task_class))) |
| 626 | |
| 627 | def revoke_all(self, task_class, revoke_until=None, revoke_once=False): |
| 628 | if isinstance(task_class, TaskWrapper): |
no test coverage detected