fix: read pip output in chunks splitting on and

training/space_runner.py

@@ -55,31 +55,44 @@ def _run_training():
     _pip_base = [sys.executable, "-m", "pip", "install", "--no-cache-dir", "--target", _PKGS]
 
     install_cmds = [
-        _pip_base + ["--progress-bar", "on", "unsloth"],
-        _pip_base + ["--progress-bar", "on",
-                     f"unsloth[cu121-ampere-{torch_tag}] @ git+https://github.com/unslothai/unsloth.git"],
-        _pip_base + ["--progress-bar", "on", "git+https://github.com/unslothai/unsloth.git"],
+        _pip_base + ["-v", "unsloth"],
+        _pip_base + ["-v", f"unsloth[cu121-ampere-{torch_tag}] @ git+https://github.com/unslothai/unsloth.git"],
+        _pip_base + ["-v", "git+https://github.com/unslothai/unsloth.git"],
     ]
+
+    def _stream_cmd(cmd):
+        """Run cmd and stream output; handles \r and \n progress lines."""
+        env = {**os.environ, "PYTHONUNBUFFERED": "1", "PIP_NO_COLOR": "1"}
+        proc = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.STDOUT,
+                                bufsize=0, env=env)
+        buf = b""
+        while True:
+            chunk = proc.stdout.read(512)
+            if not chunk:
+                break
+            buf += chunk
+            # split on \n and \r so progress lines aren't held
+            parts = buf.replace(b"\r", b"\n").split(b"\n")
+            buf = parts[-1]
+            for p in parts[:-1]:
+                line = p.decode("utf-8", errors="replace").strip()
+                if line:
+                    _append_log(line)
+        if buf.strip():
+            _append_log(buf.decode("utf-8", errors="replace").strip())
+        proc.wait()
+        return proc.returncode
+
     installed = False
     for cmd in install_cmds:
-        proc = subprocess.Popen(
-            cmd, stdout=subprocess.PIPE, stderr=subprocess.STDOUT,
-            text=True, bufsize=1,
-        )
-        lines = []
-        for line in proc.stdout:
-            line = line.rstrip()
-            if line:
-                _append_log(line)
-                lines.append(line)
-        proc.wait()
-        if proc.returncode == 0:
+        rc = _stream_cmd(cmd)
+        if rc == 0:
             if _PKGS not in sys.path:
                 sys.path.insert(0, _PKGS)
             _append_log("✅ unsloth installed successfully.")
             installed = True
             break
-        _append_log(f"⚠️ Install attempt failed (exit {proc.returncode}), trying next...")
+        _append_log(f"⚠️ Install attempt failed (exit {rc}), trying next...")
     if not installed:
         _training_status = "failed"
         _append_log("❌ All unsloth install attempts failed. Check logs above.")