Method join

t/unit/tasks/test_chord.py:38–43

(self, propagate=True, **kwargs)

        return self.is_ready

    def join(self, propagate=True, **kwargs):
        if propagate:
            for value in self.value:
                if isinstance(value, Exception):
                    raise value
        return self.value
    join_native = join

    def _failed_join_report(self):