5806e726f49885975d60bee9265371002b3ae24c,python/ray/experimental/internal_kv.py,,_internal_kv_put,#Any#Any#Any#,27

Before Change

    worker = ray.worker.global_worker

    if overwrite:
        updated = worker.redis_client.hset(key, "value", value)
    else:
        updated = worker.redis_client.hsetnx(key, "value", value)
    return updated == 0  // already exists


@client_mode_hook

After Change

        already_exists (bool): whether the value already exists.
    
    if redis:
        if overwrite:
            updated = ray.worker.global_worker.redis_client.hset(
                key, "value", value)
        else:
            updated = ray.worker.global_worker.redis_client.hsetnx(
                key, "value", value)
        return updated == 0  // already exists
    else:
        return not ray.worker.global_worker.gcs_client.kv_put(
            key, value, overwrite)

Instances