Skip to content

Commit 5f6f1b1

Browse files
n24q02mn24q02m
andauthored
fix: ruff-format test_parallel_processor.py after merge (#873)
The rebase/merge of the worker-health + check_worker_health test additions joined two test sections without a ruff pass, leaving a blank-line spacing the CI formatter rejects. Apply ruff format. Co-authored-by: n24q02m <n24q02m@outlook.com>
1 parent dccf2f0 commit 5f6f1b1

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

tests/test_parallel_processor.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -664,6 +664,8 @@ def test_semi_ordered_map_empty():
664664
assert result == []
665665
# Verify processes are joined and list is cleared
666666
assert len(pool.processes) == 0
667+
668+
667669
def test_semi_ordered_map_interrupted_no_hang():
668670
"""Test that semi_ordered_map does not hang when consumption is interrupted early."""
669671
pool = ParallelWorkerPool(worker=SlowWorker, config=PoolConfig(num_workers=1))
@@ -699,6 +701,8 @@ def test_semi_ordered_map_start_failure():
699701
# queues should be None or handled safely
700702
assert pool.input_queue is None
701703
assert pool.output_queue is None
704+
705+
702706
def test_check_worker_health_healthy():
703707
"""Test check_worker_health does not raise when all processes are alive or exited cleanly."""
704708
pool = ParallelWorkerPool(worker=SquareWorker, config=PoolConfig(num_workers=2))

0 commit comments

Comments
 (0)