from __future__ import absolute_import from celery.worker import state from celery.tests.case import AppCase class test_revoked(AppCase): def test_is_working(self): state.revoked.add('foo') self.assertIn('foo', state.revoked) state.revoked.pop_value('foo') self.assertNotIn('foo', state.revoked)