break
			}

			c.watchCache.startIndex++
		}
		c.watchCache.listResourceVersion = rv

		if _, err = client.KV.Put(ctx, "compact_rev_key", resourceVersion); err != nil {
			t.Fatalf("Could not update compact_rev_key: %v", err)
		}
		if _, err = client.Compact(ctx, int64(rv)); err != nil {
			t.Fatalf("Could not compact: %v", err)
		}
	}

	resp, err := client.KV.Txn(ctx).If(
		clientv3.Compare(clientv3.Version(compactRevKey), "=", t),
	).Then(
		clientv3.OpPut(compactRevKey, strconv.FormatInt(rev, 10)), // Expect side effect: increment Version
	).Else(
		clientv3.OpGet(compactRevKey),
	).Commit()
	if err != nil {
		return t, rev, err
	}

	curRev := resp.Header.Revision

	if !resp.Succeeded {