diff --git a/internal/engine/aggregate_test.go b/internal/engine/aggregate_test.go
index 397431f..a68004b 100644
--- a/internal/engine/aggregate_test.go
+++ b/internal/engine/aggregate_test.go
@@ -74,16 +74,3 @@ func TestAggregationEngine(t *testing.T) {
 		})
 	}
 }
-
-// ExecutePipeline 执行管道（用于测试）
-func (e *AggregationEngine) ExecutePipeline(docs []types.Document, pipeline []types.AggregateStage) ([]types.Document, error) {
-	result := docs
-	for _, stage := range pipeline {
-		var err error
-		result, err = e.executeStage(stage, result)
-		if err != nil {
-			return nil, err
-		}
-	}
-	return result, nil
-}