lib/task/worker.py
def join(self, timeout=None):
        '''
        Joins the underlying thread for this worker.

        If `timeout` is omitted, this will block indefinitely until the thread
        has exited.
        If `timeout` is provided, it should be the maximum number of seconds to
        wait until returning. If the thread is still alive after the timeout
        expires, a `TimeoutError` will be raised.
        '''
        handle = self._handle       # type: threading.Thread
        if not handle:
            # worker is already dead
            return

        handle.join(timeout=timeout)
        if handle.is_alive():
            timeout_desc = (
                ' after %rs' % (timeout) if timeout is not None else ''
            )
            raise TimeoutError('thread did not exit%s' % (timeout_desc))

        Joins the underlying thread for this worker.

        If `timeout` is omitted, this will block indefinitely until the thread
        has exited.
        If `timeout` is provided, it should be the maximum number of seconds to
        wait until returning. If the thread is still alive after the timeout
        expires, a `TimeoutError` will be raised.
        
Joins the underlying thread for this worker.
If `timeout` is omitted, this will block indefinitely until the thread
has exited.
If `timeout` is provided, it should be the maximum number of seconds to
wait until returning. If the thread is still alive after the timeout
expires, a `TimeoutError` will be raised.
Joins the underlying thread for this worker . If ` timeout ` is omitted this will block indefinitely until the thread has exited . If ` timeout ` is provided it should be the maximum number of seconds to wait until returning . If the thread is still alive after the timeout expires a ` TimeoutError ` will be raised .
def join(self, timeout=None):
        handle = self._handle       
        if not handle:
            return
        handle.join(timeout=timeout)
        if handle.is_alive():
            timeout_desc = (
                ' after %rs' % (timeout) if timeout is not None else ''
            )
            raise TimeoutError('thread did not exit%s' % (timeout_desc))
def join ( self , timeout = None ) : handle = self . _handle if not handle : return handle . join ( timeout = timeout ) if handle . is_alive ( ) : timeout_desc = ( ' after %rs' % ( timeout ) if timeout is not None else '' ) raise TimeoutError ( 'thread did not exit%s' % ( timeout_desc ) )
Joins the underlying thread for this worker.
Joins the underlying thread for this worker .
'''
        Joins the underlying thread for this worker.

        If `timeout` is omitted, this will block indefinitely until the thread
        has exited.
        If `timeout` is provided, it should be the maximum number of seconds to
        wait until returning. If the thread is still alive after the timeout
        expires, a `TimeoutError` will be raised.
        ''' # type: threading.Thread # worker is already dead
self
timeout