def set_dependency(self, upstream_task_id, downstream_task_id):
        self.get_task(upstream_task_id).set_downstream(
            self.get_task(downstream_task_id))
Add a task to the queue
dataset/ETHPy150Open airbnb/airflow/airflow/models.py/DAG.set_dependency--crossover with--dataset/ETHPy150Open Storj/dataserv-client/dataserv_client/control/Thread.py/ThreadPool.add_task