PRUNE_DELTA_THREADS_SQL = "\nSELECT thread_id FROM checkpoints\nWHERE thread_id = ANY(
%s) AND (\n metadata ? 'counters_since_delta_snapshot'\n OR metadata ? 'delta_writes_versioned'\n)\nUNION\nSELECT c.thread_id\nFROM checkpoints c\nCROSS JOIN LATERAL jsonb_each(c.checkpoint -> 'channel_values') AS v\nCROSS JOIN LATERAL (\n SELECT 1 FROM checkpoint_blobs b\n WHERE b.thread_id = c.thread_id\n AND b.checkpoint_ns = c.checkpoint_ns\n AND b.channel = v.key\n AND b.version = c.checkpoint -> 'channel_versions' ->> v.key\n LIMIT 1\n) AS snapshot\nWHERE c.thread_id = ANY(%s
) AND v.value = 'true'::jsonb\n"
