original_docstring: 
      Starts up the conveyer threads.
      
docstring: Starts up the conveyer threads.
docstring_tokens: Starts up the conveyer threads .
code: def run(once=False, total_threads=1, group_bulk=1, group_policy='rule',
          mock=False, rses=None, include_rses=None, exclude_rses=None, bulk=100, fts_source_strategy='auto',
          activities=[], sleep_time=600, retry_other_fts=False):
      """
      Starts up the conveyer threads.
      """
  
      if mock:
          logging.info('mock source replicas: enabled')
  
      working_rses = None
      if rses or include_rses or exclude_rses:
          working_rses = get_conveyor_rses(rses, include_rses, exclude_rses)
          logging.info("RSE selection: RSEs: %s, Include: %s, Exclude: %s" % (rses,
                                                                              include_rses,
                                                                              exclude_rses))
      else:
          logging.info("RSE selection: automatic")
  
      if once:
          logging.info('executing one stager iteration only')
          stager(once,
                 rses=working_rses,
                 mock=mock,
                 bulk=bulk,
                 group_bulk=group_bulk,
                 group_policy=group_policy,
                 fts_source_strategy=fts_source_strategy,
                 activities=activities,
                 retry_other_fts=retry_other_fts)
  
      else:
          logging.info('starting stager threads')
          threads = [threading.Thread(target=stager, kwargs={'rses': working_rses,
                                                             'bulk': bulk,
                                                             'group_bulk': group_bulk,
                                                             'group_policy': group_policy,
                                                             'activities': activities,
                                                             'mock': mock,
                                                             'sleep_time': sleep_time,
                                                             'fts_source_strategy': fts_source_strategy,
                                                             'retry_other_fts': retry_other_fts}) for _ in range(0, total_threads)]
  
          [thread.start() for thread in threads]
  
          logging.info('waiting for interrupts')
  
          # Interruptible joins require a timeout.
          while threads:
              threads = [thread.join(timeout=3.14) for thread in threads if thread and thread.isAlive()]
code_tokens: def run ( once = False , total_threads = 1 , group_bulk = 1 , group_policy = 'rule' , mock = False , rses = None , include_rses = None , exclude_rses = None , bulk = 100 , fts_source_strategy = 'auto' , activities = [ ] , sleep_time = 600 , retry_other_fts = False ) : if mock : logging . info ( 'mock source replicas: enabled' ) working_rses = None if rses or include_rses or exclude_rses : working_rses = get_conveyor_rses ( rses , include_rses , exclude_rses ) logging . info ( "RSE selection: RSEs: %s, Include: %s, Exclude: %s" % ( rses , include_rses , exclude_rses ) ) else : logging . info ( "RSE selection: automatic" ) if once : logging . info ( 'executing one stager iteration only' ) stager ( once , rses = working_rses , mock = mock , bulk = bulk , group_bulk = group_bulk , group_policy = group_policy , fts_source_strategy = fts_source_strategy , activities = activities , retry_other_fts = retry_other_fts ) else : logging . info ( 'starting stager threads' ) threads = [ threading . Thread ( target = stager , kwargs = { 'rses' : working_rses , 'bulk' : bulk , 'group_bulk' : group_bulk , 'group_policy' : group_policy , 'activities' : activities , 'mock' : mock , 'sleep_time' : sleep_time , 'fts_source_strategy' : fts_source_strategy , 'retry_other_fts' : retry_other_fts } ) for _ in range ( 0 , total_threads ) ] [ thread . start ( ) for thread in threads ] logging . info ( 'waiting for interrupts' ) while threads : threads = [ thread . join ( timeout = 3.14 ) for thread in threads if thread and thread . isAlive ( ) ]
short_docstring: Starts up the conveyer threads.
short_docstring_tokens: Starts up the conveyer threads .
comment: """
      Starts up the conveyer threads.
      """$SEP$# Interruptible joins require a timeout.