From 215da0850f16ca475d5af4cc24815014fa680ad2 Mon Sep 17 00:00:00 2001 From: Chris Miles Date: Mon, 7 Sep 2026 08:07:41 +0000 Subject: [PATCH] fix: scope SQLite race contract deadlines --- internal/workflow/store_contract_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/workflow/store_contract_test.go b/internal/workflow/store_contract_test.go index 9822d42..50313e8 100644 --- a/internal/workflow/store_contract_test.go +++ b/internal/workflow/store_contract_test.go @@ -1205,8 +1205,6 @@ func TestStoreContract_ConcurrentBatchJobOutcomeOwnership(t *testing.T) { func TestStoreContract_ConcurrentTerminalBatchJobOutcomeOwnership(t *testing.T) { for name, factory := range testStoreFactories(t) { t.Run(name, func(t *testing.T) { - ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) - defer cancel() for _, policy := range []struct { name string allowFailures bool @@ -1215,6 +1213,8 @@ func TestStoreContract_ConcurrentTerminalBatchJobOutcomeOwnership(t *testing.T) {name: "fail_fast", allowFailures: false}, } { t.Run(policy.name, func(t *testing.T) { + ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) + defer cancel() for iteration := range 6 { store := factory(t) outcomes := requireOutcomeStore(t, store) @@ -1338,8 +1338,6 @@ func TestStoreContract_ConcurrentDistinctBatchSettlement(t *testing.T) { for name, factory := range testStoreFactories(t) { t.Run(name, func(t *testing.T) { s := factory(t) - ctx, cancel := context.WithTimeout(context.Background(), 7*time.Second) - defer cancel() const jobCount = 32 jobs := make([]BatchJob, jobCount) for i := range jobs { @@ -1356,6 +1354,8 @@ func TestStoreContract_ConcurrentDistinctBatchSettlement(t *testing.T) { {name: "fail_fast", allowFailures: false}, } { t.Run(policy.name, func(t *testing.T) { + ctx, cancel := context.WithTimeout(context.Background(), 15*time.Second) + defer cancel() batchID := "batch-concurrent-distinct-" + policy.name if err := s.CreateBatch(ctx, BatchRecord{ BatchID: batchID,