fedn.clients.reducer.statestore package

Submodules

fedn.clients.reducer.statestore.mongoreducerstatestore module

class fedn.clients.reducer.statestore.mongoreducerstatestore.MongoReducerStateStore(network_id, config, defaults=None)[source]

Bases: ReducerStateStore

delete_combiner(combiner)[source]
drop_control()[source]
drop_models()[source]
get_client(name)[source]
get_combiner(name)[source]
get_combiners()[source]
get_compute_context()[source]
Returns:

get_config()[source]
Returns:

get_events()[source]
Returns:

get_first()[source]

Return model_id for the latest model in the model_trail

get_framework()[source]
Returns:

get_latest()[source]

Return model_id for the latest model in the model_trail

get_model_info()[source]
Returns:

get_reducer()[source]
get_round_config()[source]
Returns:

get_storage_backend()[source]
is_inited()[source]
Returns:

list_clients()[source]
list_combiners()[source]
set_client(client_data)[source]

Set or update client record. client_data: dictionarys

set_combiner(combiner_data)[source]

Set or update combiner record. combiner_data: dictionary, output of combiner.to_dict())

set_compute_context(filename)[source]
Parameters:

filename

set_framework(helper)[source]
Parameters:

helper

set_latest(model_id)[source]
Parameters:

model_id

set_reducer(reducer_data)[source]
set_round_config(config)[source]
Parameters:

config

set_storage_backend(config)[source]
state()[source]
Returns:

transition(state)[source]
Parameters:

state

Returns:

update_client_status(client_data, status, role)[source]

Set or update client status. assign roles to the active clients (trainer, validator, trainer-validator)

fedn.clients.reducer.statestore.reducerstatestore module

class fedn.clients.reducer.statestore.reducerstatestore.ReducerStateStore[source]

Bases: ABC

abstract get_latest()[source]
abstract is_inited()[source]
abstract set_latest(model_id)[source]
Parameters:

model_id

abstract state()[source]
abstract transition(state)[source]
Parameters:

state

Module contents