@property
    def upstream_list(self):
        return [self.dag.get_task(tid) for tid in self._upstream_task_ids]
@property: list of tasks directly upstream
dataset/ETHPy150Open airbnb/airflow/airflow/models.py/BaseOperator.upstream_list