[MISC] Logging the message about Ray teardown (#13502)

Signed-off-by: Cody Yu <hao.yu.cody@gmail.com>
Co-authored-by: Rui Qiao <161574667+ruisearch42@users.noreply.github.com>
This commit is contained in:
Cody Yu 2025-02-19 09:40:50 -08:00 committed by GitHub
parent 01c184b8f3
commit fbbe1fbac6
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -101,6 +101,10 @@ class RayDistributedExecutor(DistributedExecutorBase):
self.driver_worker.execute_method)
def shutdown(self) -> None:
logger.info(
"Shutting down Ray distributed executor. If you see error log "
"from logging.cc regarding SIGTERM received, please ignore because "
"this is the expected termination process in Ray.")
if hasattr(self, "forward_dag") and self.forward_dag is not None:
self.forward_dag.teardown()
import ray