Fix verbose shutdown error and test_env_with_subprocesses (#6614)

This commit is contained in:
Eric Liang
2019-12-26 22:43:39 -08:00
committed by GitHub
parent eb0813ea35
commit 46acb02aa4
3 changed files with 0 additions and 7 deletions
-5
View File
@@ -787,11 +787,6 @@ cdef class CoreWorker:
node_ip_address.encode("utf-8"), node_manager_port,
task_execution_handler, check_signals, True))
def disconnect(self):
self.destory_event_loop_if_exists()
with nogil:
self.core_worker.get().Disconnect()
def run_task_loop(self):
with nogil:
self.core_worker.get().StartExecutingTasks()
-1
View File
@@ -819,7 +819,6 @@ def exit_actor():
if worker.mode == ray.WORKER_MODE and not worker.actor_id.is_nil():
# Intentionally disconnect the core worker from the raylet so the
# raylet won't push an error message to the driver.
worker.core_worker.disconnect()
ray.disconnect()
# Disconnect global state from GCS.
ray.state.state.disconnect()
-1
View File
@@ -81,7 +81,6 @@ cdef extern from "ray/core_worker/core_worker.h" nogil:
c_vector[shared_ptr[CRayObject]] *returns) nogil,
CRayStatus() nogil,
c_bool ref_counting_enabled)
void Disconnect()
CWorkerType &GetWorkerType()
CLanguage &GetLanguage()