Lines Matching full:aggregation

32 from fcp.aggregation.protocol import aggregation_protocol_messages_pb2 as apm_pb2
33 from fcp.aggregation.protocol import configuration_pb2
34 from fcp.aggregation.protocol.python import aggregation_protocol
35 from fcp.aggregation.tensorflow.python import aggregation_protocols
53   """The status of an aggregation session."""
54   # The current state of the aggregation session.
56   # Number of clients that successfully started and completed the aggregation
59   # Number of clients that started the aggregation upload protocol but failed
62   # Number of clients that started the aggregation upload protocol but have not
65   # Number of clients that started the aggregation protocol but were aborted by
84   # outside this service. Note that aggregation does not automatically stop if
86   # to stop aggregation when they want.
95   # The client's identifier in the aggregation protocol.
98   # aggregation protocol). At most one value will be written.
134     # A queue receiving the final result of the aggregation session: either the
172   """Internal state for an aggregation session."""
173   # The session's aggregation requirements.
177   # The protocol performing the aggregation. Service._sessions_lock should not
204     """Creates a new aggregation session and returns its id."""
213     # in-process aggregation shard. In a production implementation, there should
234     """Completes the aggregation session and returns its results."""
260       logging.warning('Failed to complete aggregation session: %s', e)
267     """Aborts/cancels an aggregation session."""
282     """Returns the status of an aggregation session."""
291     """Blocks until all conditions are satisfied or the aggregation fails."""
316     """Transform an aggregation intrinsic arg for the aggregation service."""
331     """Transform the aggregation config for use by the aggregation service."""
461     # The aggregation protocol may have already closed the connect (e.g., if
475                 'Aggregation result never uploaded'))
540     # Notify the aggregation protocol that the client has left.