Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Remove task context from python worker #5987

Merged
merged 14 commits into from
Oct 25, 2019
Merged

Remove task context from python worker #5987

Changes from 1 commit
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
649ad0f
Remove task_context
edoakes Oct 23, 2019
d656bae
Use core worker job ID
edoakes Oct 23, 2019
849b1e6
Fix put_object calls
edoakes Oct 23, 2019
c6fb56e
Remove compute_put_id
edoakes Oct 23, 2019
b7c034c
Postcrement
edoakes Oct 24, 2019
818a7a3
Temporary fix
edoakes Oct 24, 2019
34b45d2
Fix memory limits
edoakes Oct 25, 2019
7009cf8
Fix already exists check
edoakes Oct 25, 2019
15c457f
move actor_id into core worker
edoakes Oct 25, 2019
ed3d914
Remove setters from cython
edoakes Oct 25, 2019
e77aa6f
Add multithreading warning in C++
edoakes Oct 25, 2019
306c9de
Fix multithreading warning
edoakes Oct 25, 2019
e071cac
Fix core worker test
edoakes Oct 25, 2019
a41bb52
Merge branch 'master' into task-context
edoakes Oct 25, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Fix already exists check
  • Loading branch information
@edoakes
edoakes committed Oct 25, 2019
commit 7009cf8a2e3abb02147b48dd77425e9b6c2f8c83
2 changes: 1 addition & 1 deletion python/ray/_raylet.pyx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -745,7 +745,7 @@ cdef class CoreWorker:
# which we ignore.
# TODO(edoakes): this is hacky, we should return the error instead
# and deal with it here.
return not data
return data.get() == NULL

def put_serialized_object(self, serialized_object, ObjectID object_id=None,
int memcopy_threads=6):
Expand Down