worker.coordinator.resource_manager

NaiveResourceManager

class ding.worker.coordinator.resource_manager.NaiveResourceManager[source]
Overview:

the naive resource manager

Interface:

__init__, assign_collector, assign_learner, update

__init__() None[source]
Overview:

init the resouce manager

assign_collector(collector_task: dict) dict[source]
Overview:

assign the collector_task randomly and return the resouce info

Arguments:
  • collector_task (dict): the collector task to assign

assign_learner(learner_task: dict) dict[source]
Overview:

assign the learner_task randomly and return the resouce info

Arguments:
  • learner_task (dict): the learner task to assign

update(name: str, worker_id: str, resource_info: dict) None[source]
Overview:

update the reource info