Fixing redis pipelining, more celery implementation