File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -1078,11 +1078,11 @@ def _validate_config(config: dict):
10781078 config ["input_evaluation" ]))
10791079
10801080 def _try_recover (self ):
1081- """Try to identify and blacklist any unhealthy workers.
1081+ """Try to identify and remove any unhealthy workers.
10821082
10831083 This method is called after an unexpected remote error is encountered
10841084 from a worker. It issues check requests to all current workers and
1085- blacklists any that respond with error. If no healthy workers remain,
1085+ removes any that respond with error. If no healthy workers remain,
10861086 an error is raised.
10871087 """
10881088
@@ -1110,7 +1110,7 @@ def _try_recover(self):
11101110 healthy_workers .append (w )
11111111 logger .info ("Worker {} looks healthy" .format (i + 1 ))
11121112 except RayError :
1113- logger .exception ("Blacklisting worker {}" .format (i + 1 ))
1113+ logger .exception ("Removing unhealthy worker {}" .format (i + 1 ))
11141114 try :
11151115 w .__ray_terminate__ .remote ()
11161116 except Exception :
You can’t perform that action at this time.
0 commit comments