Skip to content

Commit

Permalink
Only collaborators_done are used for aggregation
Browse files Browse the repository at this point in the history
Signed-off-by: Parth Mandaliya <[email protected]>
  • Loading branch information
ParthMandaliya committed Jul 9, 2024
1 parent ae82b53 commit 7a028ff
Showing 1 changed file with 1 addition and 8 deletions.
9 changes: 1 addition & 8 deletions openfl/component/aggregator/aggregator.py
Original file line number Diff line number Diff line change
Expand Up @@ -880,14 +880,7 @@ def _compute_validation_related_task_metrics(self, task_name):
# task sent
# This handles getting the subset of collaborators that may be
# part of the validation task
all_collaborators_for_task = self.assigner.get_collaborators_for_task(
task_name, self.round_number
)
# leave out stragglers for the round
collaborators_for_task = []
for c in all_collaborators_for_task:
if c in self.collaborators_done:
collaborators_for_task.append(c)
collaborators_for_task = self.collaborators_done

# The collaborator data sizes for that task
collaborator_weights_unnormalized = {
Expand Down

0 comments on commit 7a028ff

Please sign in to comment.