Use Celery as a Resque worker

celery_resque_worker.py

from carrot import serialization
from ghettoq.taproot import Redis

class Resque(Redis):

    def message_to_python(self, raw_message):
        payload = serialization.decode(raw_message,
                                       content_type="application/json",
                                       content_encoding="utf-8")
        task_class = payload["class"]
        task_args = payload["args"]

        as_celery_task = serialization.encode({"task": task_class,
                                               "args": task_args,
                                               "kwargs": {},
                                               "retries": 0,
                                               "eta": None})

        message = self.Message(backend=self, payload=as_celery_task)
        self.qos_manager.append(message, message.destination,
                                message.delivery_tag)
        return message