Skip to content

Commit

Permalink
Fix formatting errors
Browse files Browse the repository at this point in the history
  • Loading branch information
adam-narozniak committed Dec 19, 2024
1 parent fa0aa34 commit 4caff13
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ class VerticalSizePartitioner(Partitioner):
>>>
>>> partitioner = VerticalSizePartitioner(
... partition_sizes=[8, 4, 2],
... active_party_column="income",
... active_party_columns="income",
... active_party_columns_mode="create_as_last"
... )
>>> fds = FederatedDataset(
Expand Down Expand Up @@ -202,7 +202,7 @@ def _validate_parameters_in_init(self) -> None:
if all(isinstance(fraction, float) for fraction in self._partition_sizes):
fraction_sum = sum(self._partition_sizes)
# Tolerance 0.01 for the floating point numerical problems
if fraction_sum < 1.01 and fraction_sum > 0.99:
if 0.99 < fraction_sum < 1.01:
self._partition_sizes = self._partition_sizes[:-1] + [
1.0 - self._partition_sizes[-1]
]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ def test_init_invalid_mode(self) -> None:
def test_init_active_party_column_invalid_type(self) -> None:
"""Check ValueError if active_party_column is not str/list."""
with self.assertRaises(ValueError):
VerticalSizePartitioner(partition_sizes=[2, 2], active_party_column=123)
VerticalSizePartitioner(partition_sizes=[2, 2], active_party_columns=123)

def test_partitioning_with_int_sizes(self) -> None:
"""Check correct partitioning with integer sizes."""
Expand Down Expand Up @@ -124,7 +124,7 @@ def test_partitioning_with_active_party_add_to_last(self) -> None:
dataset = _create_dummy_dataset(columns)
partitioner = VerticalSizePartitioner(
partition_sizes=[2],
active_party_column="label",
active_party_columns="label",
active_party_columns_mode="add_to_last",
shuffle=False,
)
Expand All @@ -138,7 +138,7 @@ def test_partitioning_with_active_party_create_as_first(self) -> None:
dataset = _create_dummy_dataset(columns)
partitioner = VerticalSizePartitioner(
partition_sizes=[2],
active_party_column="label",
active_party_columns="label",
active_party_columns_mode="create_as_first",
shuffle=False,
)
Expand Down Expand Up @@ -166,7 +166,7 @@ def test_partitioning_with_nonexistent_active_party_column(self) -> None:
columns = ["f1", "f2"]
dataset = _create_dummy_dataset(columns)
partitioner = VerticalSizePartitioner(
partition_sizes=[1], active_party_column="missing_label", shuffle=False
partition_sizes=[1], active_party_columns="missing_label", shuffle=False
)
partitioner.dataset = dataset
with self.assertRaises(ValueError):
Expand Down

0 comments on commit 4caff13

Please sign in to comment.