def get_direct_relatives(self, upstream=False):
        if upstream:
            return self.upstream_list
        else:
            return self.downstream_list
Get the direct relatives to the current task, upstream or
dataset/ETHPy150Open airbnb/airflow/airflow/models.py/BaseOperator.get_direct_relatives