Class - WaitForAllPolicy#

class openfl.component.aggregator.straggler_handling.WaitForAllPolicy[source]#

Bases: StragglerPolicy

This policy waits for all collaborators.

__init__()#

Methods

__init__()

reset_policy_for_round()

Nothing needed.

start_policy(**kwargs)

Nothing needed.

straggler_cutoff_check(...)

Checks if all collaborators have sent task results for the round.

reset_policy_for_round()[source]#

Nothing needed.

Return type:

None

start_policy(**kwargs)[source]#

Nothing needed.

Return type:

None

straggler_cutoff_check(num_collaborators_done, num_all_collaborators, **kwargs)[source]#

Checks if all collaborators have sent task results for the round.

Parameters:
  • num_collaborators_done (int)

  • num_all_collaborators (int)

Return type:

bool