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