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

[xray] Fix heartbeat subscription for autoscaler #2498

Merged
merged 20 commits into from
Jul 28, 2018
Merged

[xray] Fix heartbeat subscription for autoscaler #2498

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
69a65a3
wip
ericl Jul 25, 2018
38d9f36
wip
ericl Jul 25, 2018
b27f5ec
up
ericl Jul 25, 2018
ec6ac41
fix
ericl Jul 26, 2018
ebc5356
wip
ericl Jul 26, 2018
74d5d83
fix
ericl Jul 26, 2018
fa62041
fix
ericl Jul 26, 2018
31246b0
fix
ericl Jul 26, 2018
1726d4d
fix
ericl Jul 26, 2018
37a09ba
Merge remote-tracking branch 'upstream/master' into fix-autoscaling
ericl Jul 27, 2018
934059d
subscribe to multiple clients
ericl Jul 27, 2018
5884d64
debug
ericl Jul 27, 2018
0d4c0ed
fix
ericl Jul 27, 2018
2afd7d8
fix
ericl Jul 27, 2018
095c7f2
revert rllib
ericl Jul 27, 2018
69ac1fb
try removing raylet
ericl Jul 27, 2018
849c0fc
branch raylet
ericl Jul 27, 2018
b178121
Separate primary client from shard clients.
robertnishihara Jul 28, 2018
faf69b0
Fix
robertnishihara Jul 28, 2018
1fbf576
Bug fix
robertnishihara Jul 28, 2018
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
up
  • Loading branch information
@ericl
ericl committed Jul 25, 2018
commit b27f5ec7db30109dc88c652bda92366c4a8339c2
2 changes: 1 addition & 1 deletion python/ray/autoscaler/autoscaler.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -485,7 +485,7 @@ def recover_if_needed(self, node_id):
return
print(
"StandardAutoscaler: No heartbeat from node "
"{} in {} seconds, restarting Ray to recover".format(
"{} in {} seconds, restarting Ray to recover...".format(
node_id, delta))
updater = self.node_updater_cls(
node_id,
Expand Down
1 change: 1 addition & 0 deletions python/ray/monitor.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -499,6 +499,7 @@ def process_messages(self, max_messages=10000):
max_messages: The maximum number of messages to process before
returning.
"""
print("PROCESS MESSAGES")
for _ in range(max_messages):
message = self.subscribe_client.get_message()
if message is None:
Expand Down