PRUNE_SUBGRAPH_CALLS_SQL = (
'DELETE FROM checkpoints WHERE thread_id = %s AND checkpoint_ns = ANY(%s)',
'DELETE FROM checkpoint_writes WHERE thread_id = %s AND checkpoint_ns = ANY(%s)',
'DELETE FROM checkpoint_blobs WHERE thread_id = %s AND checkpoint_ns = ANY(%s)'
)