def __init__(self, config):
        '''Create a new task master.

        This is a lightweight object, and it is safe to have multiple
        objects concurrently accessing the same rejester system, even
        on multiple machines.

        :param dict config: Configuration for the task master, generally
          the contents of the ``rejester`` block in the global configuration

        '''
        config['app_name'] = 'rejester'
        #: Configuration for the task master
        self.config = config
        #: Mid-level Redis interface
        self.registry = Registry(config)
        #: Worker ID, if this is tied to a worker
        self.worker_id = None
        #: Amount of time workers get between :meth:`WorkUnit.update` calls
        self.default_lifetime = config.get('default_lifetime', 900)
        #: Override available-memory checks
        self.enough_memory = config.get('enough_memory', False)
def __init__ ( self , config ) : config [ 'app_name' ] = 'rejester' self . config = config self . registry = Registry ( config ) self . worker_id = None self . default_lifetime = config . get ( 'default_lifetime' , 900 ) self . enough_memory = config . get ( 'enough_memory' , False )
Create a new task master.

        This is a lightweight object, and it is safe to have multiple
        objects concurrently accessing the same rejester system, even
        on multiple machines.

        :param dict config: Configuration for the task master, generally
          the contents of the ``rejester`` block in the global configuration