continue migrating local multiprocessing.Queue to redis queue