(self, zrevoked)
| 261 | self._revoked_tasks.purge() |
| 262 | |
| 263 | def _merge_revoked_v3(self, zrevoked): |
| 264 | if zrevoked: |
| 265 | self._revoked_tasks.update(pickle.loads(self.decompress(zrevoked))) |
| 266 | |
| 267 | def _merge_revoked_v2(self, saved): |
| 268 | if not isinstance(saved, LimitedSet): |