diff --git a/src/decentralizepy/datasets/Femnist.py b/src/decentralizepy/datasets/Femnist.py index c0360c5d8c88e013c437a4f8cac964c11d1057e7..2e80096dec27833d1909b85e80840d84b35b53fb 100644 --- a/src/decentralizepy/datasets/Femnist.py +++ b/src/decentralizepy/datasets/Femnist.py @@ -123,7 +123,8 @@ class Femnist(Dataset): self.sizes[-1] += 1.0 - frac * self.n_procs logging.debug("Size fractions: {}".format(self.sizes)) - my_clients = DataPartitioner(files, self.sizes).use(self.rank) + self.uid = self.mapping.get_uid(self.rank, self.machine_id) + my_clients = DataPartitioner(files, self.sizes).use(self.uid) my_train_data = {"x": [], "y": []} self.clients = [] self.num_samples = []