task.py 文件源码

def enqueue_blob(blob_hash, db_dir, client_factory_class, redis_address=settings['redis server'], 
                    host_infos=None):

    redis_connection = get_redis_connection(redis_address)
    q = Queue(connection=redis_connection)
    q.enqueue(process_blob, blob_hash, db_dir, client_factory_class, redis_address, host_getter, timeout=60)