fix: removed bad test

Author: ringoldsdev

tests/test_parallel_transformer.py

@@ -111,14 +111,6 @@ def test_map_with_context(self):
     result = list(transformer([1, 2, 3], context))
     assert result == [3, 6, 9]
 
-  def test_context_aware_complex_operation(self):
-    """Test complex context-aware operations with shared state."""
-    context = ParallelContextManager({"multiplier": 3, "stats": {"total": 0, "count": 0}})
-
-    transformer = createParallelTransformer(int, max_workers=2, chunk_size=2).map(update_stats)
-    data = [1, 2, 3, 4, 5]
-    result = list(transformer(data, context))
-
   def test_multiple_context_values_modification(self):
     """Test modifying multiple context values safely."""
     from laygo.context import ParallelContextManager

tests/test_pipeline.py

@@ -478,5 +478,5 @@ def context_modifier_b(chunk: list[int], ctx: PipelineContext) -> list[int]:
     assert result["branch_b"] == [3, 6, 9]
 
     # Context values should reflect the actual chunk sizes processed
-    assert pipeline.ctx.get("branch_a_processed") == 3
-    assert pipeline.ctx.get("branch_b_processed") == 3
+    assert pipeline.context_manager.get("branch_a_processed") == 3
+    assert pipeline.context_manager.get("branch_b_processed") == 3