def _do_skip_downstream_tasks(self, context: Dict) -> None:
    downstream_tasks = context['task'].get_flat_relatives(upstream=False)
    self.log.debug('Downstream task_ids %s', downstream_tasks)
    if downstream_tasks:
        self.skip(context['dag_run'], context['ti'].execution_date, downstream_tasks)
def _do_skip_downstream_tasks(self, context: Dict) -> None:
    downstream_tasks = context['task'].get_flat_relatives(upstream=False)
    self.log.debug('Downstream task_ids %s', downstream_tasks)
    if downstream_tasks:
        self.skip(context['dag_run'], context['ti'].execution_date, downstream_tasks)