General fixes to running commands on windows:

- base64 encode powershell commands
- fallback to run_cmd_subprocess in run_cmd_async because of event loop shenanigans
- silence additional powershell outputs

Author: Your Name

cecli/run_cmd.py

@@ -1,4 +1,5 @@
 import asyncio
+import base64
 import os
 import platform
 import subprocess
@@ -54,8 +55,11 @@ def run_cmd_subprocess(
         if platform.system() == "Windows":
             parent_process = get_windows_parent_process_name()
             if parent_process == "powershell.exe":
-                command = f"powershell -Command {command}"
-
+                # Silence progress/error streams at the source to prevent CLIXML
+                silenced_command = f"$ProgressPreference='SilentlyContinue'; {command}"
+                cmd_bytes = silenced_command.encode("utf-16-le")
+                encoded = base64.b64encode(cmd_bytes).decode()
+                command = f"powershell -NoProfile -NonInteractive -OutputFormat Text -EncodedCommand {encoded}"
         if verbose:
             print("Running command:", command)
             print("SHELL:", shell)
@@ -93,7 +97,7 @@ def run_cmd_subprocess(
                     print(line, end="", flush=True)
 
         process.wait()
-        return process.returncode, "".join(output)
+        return process.returncode, _clean_output("".join(output))
     except Exception as e:
         return 1, str(e)
 
@@ -116,7 +120,11 @@ async def run_cmd_async(
     if platform.system() == "Windows":
         parent_process = get_windows_parent_process_name()
         if parent_process == "powershell.exe":
-            command = f"powershell -Command {command}"
+            # Silence progress/error streams at the source to prevent CLIXML
+            silenced_command = f"$ProgressPreference='SilentlyContinue'; {command}"
+            cmd_bytes = silenced_command.encode("utf-16-le")
+            encoded = base64.b64encode(cmd_bytes).decode()
+            command = f"powershell -NoProfile -NonInteractive -OutputFormat Text -EncodedCommand {encoded}"
 
     if verbose:
         print("Running command:", command)
@@ -131,6 +139,19 @@ async def run_cmd_async(
             stderr=asyncio.subprocess.STDOUT,
             cwd=cwd,
         )
+    except NotImplementedError:
+        # On Windows with SelectorEventLoop, asyncio does not support subprocesses.
+        # Fall back to synchronous subprocess via loop.run_in_executor.
+        loop = asyncio.get_running_loop()
+        return await loop.run_in_executor(
+            None,
+            run_cmd_subprocess,
+            command,
+            verbose,
+            cwd,
+            encoding,
+            should_print,
+        )
     except FileNotFoundError:
         return 1, f"Command not found: {command}"
 
@@ -175,7 +196,7 @@ async def read_stream(stream):
     if not reader_task.done():
         await reader_task
 
-    return process.returncode, "".join(output)
+    return process.returncode, _clean_output("".join(output))
 
 
 def run_cmd_pexpect(command, verbose=False, cwd=None, should_print=True):
@@ -222,3 +243,26 @@ def output_callback(b):
     except (pexpect.ExceptionPexpect, TypeError, ValueError) as e:
         error_msg = f"Error running command {command}: {e}"
         return 1, error_msg
+
+
+def _clean_output(output):
+    """Remove CLIXML progress output from PowerShell commands."""
+    if platform.system() != "Windows":
+        return output
+
+    if output.startswith("#< CLIXML"):
+        lines = output.splitlines()
+        filtered = []
+        for line in lines:
+            # Skip the CLIXML header line
+            if line.startswith("#< CLIXML"):
+                continue
+            # Skip CLIXML XML object tags (progress messages)
+            stripped = line.strip()
+            if stripped.startswith("<Objs ") or stripped == "</Objs>":
+                continue
+            if stripped.startswith("<Obj "):
+                continue
+            filtered.append(line)
+        return "\n".join(filtered)
+    return output

tests/basic/test_run_cmd.py

@@ -4,8 +4,8 @@
 
 
 def test_run_cmd_echo():
-    command = "echo Hello, World!"
+    command = "echo 'Hello World'"
     exit_code, output = run_cmd(command)
 
     assert exit_code == 0
-    assert output.strip() == "Hello, World!"
+    assert output.strip() == "Hello World"

tests/helpers/monorepo/test_repomap_workspace.py

@@ -18,6 +18,8 @@ def mock_workspace(tmp_path):
     p1_dir = workspace_root / "p1" / "main"
     p1_dir.mkdir(parents=True)
     subprocess.run(["git", "init"], cwd=p1_dir, check=True)
+    subprocess.run(["git", "config", "user.email", "test@test.com"], cwd=p1_dir, check=True)
+    subprocess.run(["git", "config", "user.name", "Test"], cwd=p1_dir, check=True)
     (p1_dir / "file1.py").write_text("def func1(): pass")
     subprocess.run(["git", "add", "file1.py"], cwd=p1_dir, check=True)
     subprocess.run(["git", "commit", "-m", "p1 init"], cwd=p1_dir, check=True)
@@ -26,6 +28,8 @@ def mock_workspace(tmp_path):
     p2_dir = workspace_root / "p2" / "main"
     p2_dir.mkdir(parents=True)
     subprocess.run(["git", "init"], cwd=p2_dir, check=True)
+    subprocess.run(["git", "config", "user.email", "test@test.com"], cwd=p2_dir, check=True)
+    subprocess.run(["git", "config", "user.name", "Test"], cwd=p2_dir, check=True)
     (p2_dir / "file2.py").write_text("def func2(): pass")
     subprocess.run(["git", "add", "file2.py"], cwd=p2_dir, check=True)
     subprocess.run(["git", "commit", "-m", "p2 init"], cwd=p2_dir, check=True)