Missed TensorFlow World? Check out the recap. Learn more

tff.framework.create_worker_pool_executor

View source on GitHub

Create an executor backed by a worker pool.

tff.framework.create_worker_pool_executor(
    executors,
    max_fanout=100
)

Args:

  • executors: A list of tff.framework.Executor instances that forward work to workers in the worker pool. These can be any type of executors, but in most scenarios, they will be instances of tff.framework.RemoteExecutor.
  • max_fanout: The maximum fanout at any point in the aggregation hierarchy. If num_clients > max_fanout, the constructed executor stack will consist of multiple levels of aggregators. The height of the stack will be on the order of log(num_clients) / log(max_fanout).

Returns:

An instance of tff.framework.Executor.