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
Revert "revert auto init hook" 
This reverts commit 53cfcbb.
  • Loading branch information
@ericl
ericl committed Nov 30, 2023
commit 67c06c997853880fe95502e4cd1a86835ba0c2f7
6 changes: 2 additions & 4 deletions python/ray/_private/auto_init_hook.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,13 +4,11 @@
import threading

auto_init_lock = threading.Lock()
enable_auto_connect = os.environ.get("RAY_ENABLE_AUTO_CONNECT", "") != "0"


def auto_init_ray():
if (
os.environ.get("RAY_ENABLE_AUTO_CONNECT", "") != "0"
and not ray.is_initialized()
):
if enable_auto_connect and not ray.is_initialized():
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

+1

Beat me to fixing this. It's a small thing but notoriously showing up in every profile

auto_init_lock.acquire()
if not ray.is_initialized():
ray.init()
Expand Down