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

[core] Small optimizations from accelerated DAG experiment #41418

Merged
merged 12 commits into from
Nov 30, 2023
Merged

[core] Small optimizations from accelerated DAG experiment #41418

Changes from 1 commit
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
a983e06
point optimizations
ericl Nov 27, 2023
979c858
revert bytes check
ericl Nov 27, 2023
5d31c89
comments
ericl Nov 28, 2023
53a8d8a
fix comment
ericl Nov 29, 2023
dbd2a33
fix segfault
ericl Nov 29, 2023
18f68f6
Merge remote-tracking branch 'upstream/master' into misc-opt
ericl Nov 29, 2023
a019d22
switch to static const
ericl Nov 29, 2023
53cfcbb
revert auto init hook
ericl Nov 30, 2023
e818378
clear job id on shutdown
ericl Nov 30, 2023
67c06c9
Revert "revert auto init hook"
ericl Nov 30, 2023
fb44860
add back auto connect for test
ericl Nov 30, 2023
922ec8f
fix
ericl Nov 30, 2023
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
clear job id on shutdown 
Signed-off-by: Eric Liang <ekhliang@gmail.com>
  • Loading branch information
@ericl
ericl committed Nov 30, 2023
commit e818378e623f3eb9c49456391590e1f6172259f1
1 change: 1 addition & 0 deletions python/ray/_private/worker.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1802,6 +1802,7 @@ def shutdown(_exiting_interpreter: bool = False):
# TODO(rkn): Instead of manually resetting some of the worker fields, we
# should simply set "global_worker" to equal "None" or something like that.
global_worker.set_mode(None)
global_worker.set_cached_job_id(None)


atexit.register(shutdown, True)
Expand Down