chore: tweak log message for when worker process dies
@@ -287,7 +287,7 @@ class SubprocessLauncher:
for subprocess_id in self._worker_process_ids:
if not psutil.pid_exists(subprocess_id):
- raise det.errors.WorkerError("Training process died.")
+ raise det.errors.WorkerError("Detected that worker process died.")
def _send_recv_workload(self, wkld: workload.Workload, args: List[Any]) -> workload.Response:
# Broadcast every workload to every worker on this machine.
