replace threading/queue with celery task queue