'Simple utility method to set dependency between two tasks that
already have been added to the DAG using add_task()'

def set_dependency(self, upstream_task_id, downstream_task_id):

    self.get_task(upstream_task_id).set_downstream(self.get_task(downstream_task_id))
