s4cmd.py
def join(self):
    '''Utility function to wait all tasks to complete'''
    self.tasks.join()

    # Force each thread to break loop.
    for worker in self.workers:
      self.tasks.put(None)

    # Wait for all thread to terminate.
    for worker in self.workers:
      worker.join()
      worker.s3 = None
def join(self):
    '''Utility function to wait all tasks to complete'''
    self.tasks.join()

    # Force each thread to break loop.
    for worker in self.workers:
      self.tasks.put(None)

    # Wait for all thread to terminate.
    for worker in self.workers:
      worker.join()
      worker.s3 = None
def join ( self ) : self . tasks . join ( ) # Force each thread to break loop. for worker in self . workers : self . tasks . put ( None ) # Wait for all thread to terminate. for worker in self . workers : worker . join ( ) worker . s3 = None
Utility function to wait all tasks to complete
Utility function to wait all tasks to complete