From 328fabf358552f44c46b9c9c8a85fd2c9baf9491 Mon Sep 17 00:00:00 2001 From: Adam Narozniak Date: Tue, 28 May 2024 09:40:11 +0200 Subject: [PATCH] Change event names to past tense --- datasets/flwr_datasets/federated_dataset.py | 2 +- datasets/flwr_datasets/partitioner/partitioner.py | 2 +- datasets/flwr_datasets/telemetry.py | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/datasets/flwr_datasets/federated_dataset.py b/datasets/flwr_datasets/federated_dataset.py index 9470e8b657a4..3ab74006a94a 100644 --- a/datasets/flwr_datasets/federated_dataset.py +++ b/datasets/flwr_datasets/federated_dataset.py @@ -102,7 +102,7 @@ def __init__( # Indicate if the dataset is prepared for `load_partition` or `load_split` self._dataset_prepared: bool = False event( - EventType.FEDERATED_DATASET_CREATE, + EventType.FEDERATED_DATASET_CREATED, { "dataset_name": self._dataset_name, "partitioners_ids": [ diff --git a/datasets/flwr_datasets/partitioner/partitioner.py b/datasets/flwr_datasets/partitioner/partitioner.py index 12123d2432a8..37fa7102c186 100644 --- a/datasets/flwr_datasets/partitioner/partitioner.py +++ b/datasets/flwr_datasets/partitioner/partitioner.py @@ -32,7 +32,7 @@ class Partitioner(ABC): def __init__(self) -> None: self._dataset: Optional[Dataset] = None event( - EventType.PARTITIONER_CREATE, + EventType.PARTITIONER_CREATED, {"class_name": self.__class__.__name__, "id": id(self)}, ) diff --git a/datasets/flwr_datasets/telemetry.py b/datasets/flwr_datasets/telemetry.py index 941a128b788b..de62184d174f 100644 --- a/datasets/flwr_datasets/telemetry.py +++ b/datasets/flwr_datasets/telemetry.py @@ -119,8 +119,8 @@ def _generate_next_value_(name: str, start: int, count: int, last_values: List[A PING = auto() - FEDERATED_DATASET_CREATE = auto() - PARTITIONER_CREATE = auto() + FEDERATED_DATASET_CREATED = auto() + PARTITIONER_CREATED = auto() # Use the ThreadPoolExecutor with max_workers=1 to have a queue