-
Notifications
You must be signed in to change notification settings - Fork 5.5k
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.
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 ray.tasks() from API. #7807
Conversation
cc @edoakes regarding removing |
Can one of the admins verify this patch? |
Test PASSed. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Beautiful! I believe we can also remove the TaskSpec
and Task
wrappers in includes/task.pxi
and includes/task.pxd
now. Could you try tearing those out too?
# TODO(edoakes): there are dummy object IDs being created in | ||
# includes/task.pxi before the core worker is initialized. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@edoakes can you confirm that it's ok to remove this comment?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This comment means we should be able to remove the hasattr
check below and the related in_core_worker
flag. Let's either remove those or leave the TODO modified to say those can be removed now.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done. Initially tried removing the code, but ran into some errors, so decided to just update the comment.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
In particular, ran into the error
AttributeError: 'Worker' object has no attribute 'core_worker'
here
@@ -167,6 +167,39 @@ def f(): | |||
assert "success" in out | |||
|
|||
|
|||
def test_cleanup_on_driver_exit(call_ray_start): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Adding this test to replace test_monitors.py
(which wasn't even being run anyway).
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks great!
Test FAILed. |
Test FAILed. |
This reverts commit e254d58.
Test FAILed. |
This also removes some other unnecessary code.