Save the date! Google I/O returns May 18-20 Register now


Create an executor backed by remote workers.

channels A list of grpc.Channels hosting services which can execute TFF work.
rpc_mode A string specifying the connection mode between the local host and channels.
thread_pool_executor Optional concurrent.futures.Executor used to wait for the reply to a streaming RPC message. Uses the default Executor if not specified.
dispose_batch_size The batch size for requests to dispose of remote worker values. Lower values will result in more requests to the remote worker, but will result in values being cleaned up sooner and therefore may result in lower memory usage on the remote worker.
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).

An instance of executor_factory.ExecutorFactory encapsulating the executor construction logic specified above.