PRUNE_CHECKPOINTS_SQL = "\nWITH deleted AS (
\n DELETE FROM checkpoints\n WHERE thread_id = %s AND checkpoint_ns = %s AND checkpoint_id <> ALL(%s)\n RETURNING checkpoint -> 'channel_versions' AS versions\n)\nSELECT DISTINCT v.key AS channel, v.value AS version\nFROM deleted\nCROSS JOIN LATERAL jsonb_each_text(deleted.versions
) AS v\n"