Missed TensorFlow Dev Summit? Check out the video playlist. Watch recordings

tff.framework.ComposingExecutor

View source on GitHub

An executor composed of subordinate executors that manage disjoint scopes.

Inherits From: Executor

tff.framework.ComposingExecutor(
    parent_executor, child_executors
)

This executor can be used to construct multi-level hierarchical aggregation structures with federated executors managing disjoint subsets of clients at the leaf level.

The intrinsics currently implemented include:

  • federated_aggregate
  • federated_apply
  • federated_broadcast
  • federated_eval
  • federated_map
  • federated_mean
  • federated_sum
  • federated_value
  • federated_weighted_mean
  • federated_zip

Args:

  • parent_executor: The parent executor to use for all processing at the parent, such as combining values from child executors, unplaced and server-side processing, etc.
  • child_executors: The list of executors that manage disjoint scopes to combine in this executor, delegate to and collect or aggregate from.

Raises:

  • ValueError: If parent_executor is not an Executor instance, or child_executors is not a list of Exector instances.

Methods

close

View source

close()

Release resources associated with this Executor, if any.

If the executor has one or more target Executors, implementation of this method must close them.

create_call

View source

create_call(
    *fn_args, **fn_kwargs
)

create_selection

View source

create_selection(
    *fn_args, **fn_kwargs
)

create_tuple

View source

create_tuple(
    *fn_args, **fn_kwargs
)

create_value

View source

create_value(
    *fn_args, **fn_kwargs
)