'Implements Self >> Other == self.set_downstream(other)
If "Other" is a DAG, the DAG is assigned to the Operator.'

def __rshift__(self, other):

    if isinstance(other, DAG):
        if (not (self.has_dag() and (self.dag is other))):
            self.dag = other
    else:
        self.set_downstream(other)
    return other
