

@classmethod
def run(cls, pool_size=5, queues=[], server='localhost:6379', password=None, interval=2, logging_level=logging.INFO, log_file=None, minions_interval=5, concat_minions_logs=False, max_jobs=0):
    worker = cls(pool_size=pool_size, queues=queues, server=server, password=password, logging_level=logging_level, log_file=log_file, minions_interval=minions_interval, concat_minions_logs=concat_minions_logs, max_jobs=max_jobs)
    worker.work(interval=interval)

dataset/ETHPy150Open binarydud/pyres/pyres/horde.py Khan.run/original