raw.py 文件源码

def test_celery_task_revoke_in_queue(self, params):
        # Fill up queue
        blockers = []
        for _ in range(0, multiprocessing.cpu_count()):
            blockers .append(cancelable.delay(sleep_interval=0.1))

        result = cancelable.delay()
        result.revoke()

        assert wait_for_status(self.getCurrentUser(), result.job, JobStatus.CANCELED)

        # Now clean up the blockers
        for blocker in blockers:
            blocker.revoke()

        return result.job