nebula.core.aggregation.aggregator

Exceptions

AggregatorException

Common base class for all non-exit exceptions.

Classes

Aggregator

Helper class that provides a standard way to create an ABC using

Functions

create_aggregator(config, engine)
create_target_aggregator(config, engine)
create_malicious_aggregator(aggregator, attack)

Module Contents

exception nebula.core.aggregation.aggregator.AggregatorException

Bases: Exception

Common base class for all non-exit exceptions.

nebula.core.aggregation.aggregator.create_aggregator(config, engine)

nebula.core.aggregation.aggregator.create_target_aggregator(config, engine)

class nebula.core.aggregation.aggregator.Aggregator(config=None, engine=None)

Bases: abc.ABC

Helper class that provides a standard way to create an ABC using inheritance.

config

engine

property cm

abstract run_aggregation(models)

async update_federation_nodes(federation_nodes)

set_waiting_global_update()

async reset()

get_nodes_pending_models_to_aggregate()

async include_model_in_buffer(model, weight, source=None, round=None, local=False)

async get_aggregation()

async include_next_model_in_buffer(model, weight, source=None, round=None)

print_model_size(model)

nebula.core.aggregation.aggregator.create_malicious_aggregator(aggregator, attack)