deleted = set(session.query(models.DagRun)
            .filter(models.DagRun.id.in_(ids))