'Run a set of task instances for a date range.'

def run(self, start_date=None, end_date=None, ignore_first_depends_on_past=False, ignore_ti_state=False, mark_success=False):

    start_date = (start_date or self.start_date)
    end_date = (end_date or self.end_date or datetime.now())
    for dt in self.dag.date_range(start_date, end_date=end_date):
        TaskInstance(self, dt).run(mark_success=mark_success, ignore_depends_on_past=((dt == start_date) and ignore_first_depends_on_past), ignore_ti_state=ignore_ti_state)
