调度器 - 使用 Pyro4 远程运行作业

class hpbandster.core.dispatcher.Dispatcher(new_result_callback, run_id='0', ping_interval=10, nameserver='localhost', nameserver_port=None, host=None, logger=None, queue_callback=None)

调度器负责将任务分配给空闲的工作器，向 master 报告结果，并与命名服务器通信。

参数

• new_result_callback (function) – 将以 Job 实例 作为参数调用的函数。可以从 Job 读取结果，例如进行日志记录。
• run_id (str) – 与 HPB 运行相关的唯一运行 ID
• ping_interval (int) – 检查工作器的频率（以秒为单位）
• nameserver (str) – Pyro4 命名服务器的地址
• nameserver_port (int) – Pyro4 命名服务器的端口
• host (str) – 要使用的网络接口的 IP（或解析为该 IP 的名称）
• logger (logging.Logger) – 用于信息和调试的日志记录器实例
• queue_callback (function) – 在每个更新周期中，会以池中工作器的数量作为参数调用

discover_workers()

job_runner()

number_of_workers()

register_result(id=None, result=None)

run()

shutdown(shutdown_workers=False)

shutdown_all_workers(rediscover=False)

submit_job(id, **kwargs)

trigger_discover_worker()

class hpbandster.core.dispatcher.Job(id, **kwargs)

recreate_from_run(run)

time_it(which_time)

class hpbandster.core.dispatcher.Worker(name, uri)

is_alive()

is_busy()

shutdown()