1import * as Effect from "effect/Effect";
2import * as Cache from "./Cache.ts";
3
4export const batchSize = 256;
5
6export const run = Effect.fn("TaskCache.cleanup")(function* () {
7 const cache = yield* Cache.Cache;
8 // Three full batches stay below D1’s 1,000-query invocation limit.
9 yield* Effect.all([cache.cleanup, cache.cleanup, cache.cleanup], {
10 concurrency: 3,
11 discard: true,
12 });
13});