From da5215cb1f18c031e0e542245d6d471356ba83ae Mon Sep 17 00:00:00 2001 From: Jack Date: Wed, 5 Aug 2026 19:08:52 +0800 Subject: [PATCH] test(task): expect 1 chunk after #17739 global merge (#17841) --- internal/ingestion/task/pipeline_real_integration_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/ingestion/task/pipeline_real_integration_test.go b/internal/ingestion/task/pipeline_real_integration_test.go index cc6ca70719..c9a0edad79 100644 --- a/internal/ingestion/task/pipeline_real_integration_test.go +++ b/internal/ingestion/task/pipeline_real_integration_test.go @@ -123,8 +123,8 @@ func TestPipelineExecutor_Run_RealCanvasDSL_UsesGeneralPipeline(t *testing.T) { if len(inserted) != 1 { t.Fatalf("insert calls = %d, want 1", len(inserted)) } - if len(inserted[0]) != 2 { - t.Fatalf("inserted chunk count = %d, want 2", len(inserted[0])) + if len(inserted[0]) != 1 { + t.Fatalf("inserted chunk count = %d, want 1", len(inserted[0])) } for i, ck := range inserted[0] { if got := ck["doc_id"]; got != docID { @@ -354,8 +354,8 @@ func TestRunPipeline_RealPipelineOutput_ProducesIndexFields(t *testing.T) { t.Fatalf("insert calls = %d, want 1", len(inserted)) } chunks := inserted[0] - if len(chunks) != 2 { - t.Fatalf("inserted chunk count = %d, want 2", len(chunks)) + if len(chunks) != 1 { + t.Fatalf("inserted chunk count = %d, want 1", len(chunks)) } for i, ck := range chunks { if got := ck["doc_id"]; got != docID {