Distributed Centralized Trainign Utils#

serial_aggregation(server_storage, client_id, client_msg, train_split_name, aggregator, train_weight=None, other_weight=None, purge_msg=True)[source]#

To serially aggregate received message from a client

Parameters

  • server_storage (Storage) -- server storage object

  • client_id (int) -- client id.

  • client_msg (Mapping) -- client message.

  • train_split_name (str) -- name of the training split on clients

  • aggregator (SerialAggregator) -- a serial aggregator to accumulate info.

  • train_weight (float, optional) -- aggregation weight for trianing parameters. If not specified, uses sample number. Defaults to None.

  • other_weight (float, optional) -- aggregation weight for any other factor/metric. If not specified, uses sample number. Defaults to None.

Returns

bool -- success of aggregation.