hiro/ray
1
0
Fork 0
mirror of https://github.com/vale981/ray synced 2025-03-06 18:41:40 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

[core] Remove "plasma promotion" for serialized ObjectRefs

Browse source
This commit is contained in:
Stephanie Wang 2021-10-01 10:39:55 -07:00 • committed by GitHub
parent b0a5564f4e
commit c052395f4e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
python/ray/_raylet.pyx
View file

@ -1726,7 +1726,6 @@ cdef class CoreWorker:
CObjectID c_object_id = object_ref.native() CObjectID c_object_id = object_ref.native()
CAddress c_owner_address = CAddress() CAddress c_owner_address = CAddress()
c_string serialized_object_status c_string serialized_object_status
CCoreWorkerProcess.GetCoreWorker().PromoteObjectToPlasma(c_object_id)
CCoreWorkerProcess.GetCoreWorker().GetOwnershipInfo( CCoreWorkerProcess.GetCoreWorker().GetOwnershipInfo(
c_object_id, &c_owner_address, &serialized_object_status) c_object_id, &c_owner_address, &serialized_object_status)
return (object_ref, return (object_ref,

1
src/ray/core_worker/core_worker.cc
View file

@ -1025,6 +1025,7 @@ void CoreWorker::PutObjectIntoPlasma(const RayObject &object, const ObjectID &ob
} }
void CoreWorker::PromoteObjectToPlasma(const ObjectID &object_id) { void CoreWorker::PromoteObjectToPlasma(const ObjectID &object_id) {
// TODO(swang): Remove.
auto value = memory_store_->GetOrPromoteToPlasma(object_id); auto value = memory_store_->GetOrPromoteToPlasma(object_id);
if (value) { if (value) {
PutObjectIntoPlasma(*value, object_id); PutObjectIntoPlasma(*value, object_id);