package rootparticipation import ( "errors" "testing" ) func TestPlan14Fix2AcquisitionCommitFailureClearsPending(t *testing.T) { l := censusFixture(t) failure := errors.New("commit failed") if err := l.Acquire(t.Context(), func() error { return failure }); !errors.Is(err, failure) { t.Fatal(err) } c, err := l.Census() if err != nil || c.Pending != "" { t.Fatalf("pending acquisition survived failed commit: %+v %v", c, err) } if err := l.BeginUpdate(t.Context(), "next"); err != nil { t.Fatal("failed acquisition wedged update", err) } }