From 172ff76fb892fadd2a98b21d0347e2d67a051670 Mon Sep 17 00:00:00 2001 From: Efremenko Arhip Date: Mon, 27 Jul 2026 11:29:52 +0300 Subject: [PATCH] fix(test): update NewCompleteTask call to new signature Pass workers/results repos and quorum in the postgres integration test, matching the constructor change that added quorum voting. --- coordinator/internal/storage/postgres/integration_test.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/coordinator/internal/storage/postgres/integration_test.go b/coordinator/internal/storage/postgres/integration_test.go index 4a97a7d..ba974c3 100644 --- a/coordinator/internal/storage/postgres/integration_test.go +++ b/coordinator/internal/storage/postgres/integration_test.go @@ -406,8 +406,9 @@ func TestCompleteTaskReplayIsIdempotent(t *testing.T) { job, _ := seedJob(t, pool, 1) tasks, jobs, artifacts, tx := NewTaskRepo(pool), NewJobRepo(pool), NewArtifactRepo(pool), NewTxManager(pool) + workers, results := NewWorkerRepo(pool), NewTaskResultRepo(pool) clk := fixedClock{now: time.Now().UTC()} - uc := usecase.NewCompleteTask(tasks, jobs, artifacts, tx, clk) + uc := usecase.NewCompleteTask(tasks, jobs, artifacts, workers, results, tx, clk, 2) claimed, err := tasks.ClaimNext(ctx, usecase.ClaimFilter{ Owner: "worker-1", Now: clk.now, LeaseUntil: clk.now.Add(time.Minute),