'Get the direct relatives to the current task, upstream or
downstream.'

def get_direct_relatives(self, upstream=False):

    if upstream:
        return self.upstream_list
    else:
        return self.downstream_list
