Skip to content

Commit 834ef56

Browse files
rustyconoverclaude
andcommitted
Run the stderr-capture test on one direct worker
It fanned echo out to a direct worker per core — 48 processes for one test on a 48-core box. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
1 parent 3b6f9ab commit 834ef56

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

‎tests/table_in_out/test_client.py‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,9 @@ class TestWorkerStderrCapture:
231231

232232
def test_captures_worker_stderr(self, simple_batches: list[pa.RecordBatch]) -> None:
233233
"""Should capture stderr output from the worker process."""
234-
with Client(SUBPROCESS_FIXTURE_WORKER, pool=None) as client:
234+
# One worker: stderr capture needs a process, not echo's fan-out (a
235+
# direct worker per core).
236+
with Client(SUBPROCESS_FIXTURE_WORKER, pool=None, worker_limit=1) as client:
235237
# The example worker uses logging which writes to stderr
236238
list(
237239
client.table_in_out_function(

0 commit comments

Comments
 (0)