delete = sa.delete(queue).where(
            queue.c.get(cls.primary).in_(record_ids)