[WIP][core] Fix crash during shutdown

python/ray/_private/worker.py

@@ -938,7 +938,7 @@ def main_loop(self):
 
         def sigterm_handler(signum, frame):
             raise_sys_exit_with_custom_error_message(
-                "The process receives a SIGTERM.", exit_code=1
+                "The process received a SIGTERM", exit_code=1
             )
             # Note: shutdown() function is called from atexit handler.
 

python/ray/_raylet.pyx

@@ -2368,12 +2368,13 @@ cdef CRayStatus task_execution_handler(
                 # This means the system exit was
                 # normal based on the python convention.
                 # https://docs.python.org/3/library/sys.html#sys.exit
-                msg = f"Worker exits with an exit code {e.code}."
+                print("RETURNING FROM HERE!")
+                msg = f"The worker exited with exit code {e.code}."
                 if hasattr(e, "ray_terminate_msg"):
                     msg += (f" {e.ray_terminate_msg}")
                 return CRayStatus.IntentionalSystemExit(msg)
             else:
-                msg = f"Worker exits with an exit code {e.code}."
+                msg = f"The worker exited with exit code {e.code}."
                 # In K8s, SIGTERM likely means we hit memory limits, so print
                 # a more informative message there.
                 if "KUBERNETES_SERVICE_HOST" in os.environ: