@classmethod
    def join(cls, t, timeout = -1):
        if t.has_finished():
            return t._get_result()
        if t._join_channel is not None:
            assert False, "Tasklet can only be joined once"
        t._join_channel = Channel()
        try:
            _ = t._join_channel.receive(timeout)
            return t._get_result() 
        finally:
            t._join_channel = None
The current task will block and wait for the given task *t* to complete. When *t* is finished, this method will return
dataset/ETHPy150Open concurrence/concurrence/lib/concurrence/core.py/Tasklet.join