fixes

openfl-docker/Dockerfile.collaborator

@@ -8,4 +8,3 @@ COPY ./requirements.txt .
 RUN pip install --no-cache-dir -r requirements.txt
 
 COPY . .
-

openfl-tutorials/interactive_api/PyTorch_Kvasir_UNet/director/director_config.yaml

@@ -13,5 +13,3 @@ settings:
       HTTP_PROXY:
       HTTPS_PROXY:
       NO_PROXY:
-
-

openfl-tutorials/interactive_api/numpy_linear_regression/envoy/linreg_shard_descriptor.py

@@ -33,7 +33,7 @@ def get_dataset(self, dataset_type: str) -> np.ndarray:
         """
         Return a shard dataset by type.
 
-        A simple list with elements (x, y) implemets the Shard Dataset interface.
+        A simple list with elements (x, y) implements the Shard Dataset interface.
         """
         if dataset_type == 'train':
             return self.data[:self.n_samples // 2]

openfl/component/aggregator/aggregator.py

@@ -903,7 +903,6 @@ def _compute_validation_related_task_metrics(self, task_name) -> bool:
                         self.best_model_score = agg_results
                         self._save_model(round_number, self.best_state_path)
                         is_best_model = True
-                        # self.upload_model_to_aggregator(model_type='best')
             if 'trained' in tags:
                 self._prepare_trained(tensor_name, origin, round_number, report, agg_results)
         return is_best_model

openfl/component/director/director.py

@@ -89,11 +89,8 @@ async def set_new_experiment(
             experiment_archive_path: Path,
     ) -> bool:
         """Set new experiment."""
-        tensor_dict_path = (
-                Path('tmp') /
-                f'{uuid.uuid4()}' /
-                f'{experiment_name}.pickle'
-        ).absolute()
+        tensor_dict_path = Path('tmp') / f'{uuid.uuid4()}' / f'{experiment_name}.pickle'
+        tensor_dict_path = tensor_dict_path.absolute()
         tensor_dict_path.parent.mkdir(parents=True, exist_ok=True)
 
         with tensor_dict_path.open('wb') as f:

openfl/component/envoy/envoy.py

@@ -65,8 +65,6 @@ def __init__(
         self.shard_descriptor = shard_descriptor
         self.shard_descriptor_config = shard_descriptor_config
         self.cuda_devices = tuple(cuda_devices)
-        print(f'{cuda_devices=}')
-        logger.info(f'{cuda_devices=}')
         # Optional plugins
         self.cuda_device_monitor = cuda_device_monitor
 
@@ -75,6 +73,8 @@ def __init__(
         self.is_experiment_running = False
         self._health_check_future = None
         self.docker_config = docker_config
+        envoy_info = '\n'.join([f'{k}={v}' for k, v in self.__dict__.items()])
+        logger.info(f'Envoy Info: \n{envoy_info}')
 
     async def run(self):
         """Run of the envoy working cycle."""

openfl/component/envoy/run_collaborator.py

@@ -71,7 +71,6 @@ def _shard_descriptor_from_config(shard_config: dict):
 
 if __name__ == '__main__':
     args = _parse_args()
-    print(args.name)
     with open(args.shard_config) as f:
         shard_descriptor_config = yaml.safe_load(f)
     shard_descriptor = _shard_descriptor_from_config(shard_descriptor_config)

openfl/utilities/workspace.py

@@ -79,7 +79,7 @@ def __exit__(self, exc_type, exc_value, traceback):
         shutil.rmtree(self.experiment_name, ignore_errors=True)
         if self.experiment_work_dir in sys.path:
             sys.path.remove(self.experiment_work_dir)
-        os.remove(self.data_file_path)
+        self.data_file_path.unlink(missing_ok=True)
 
 
 def dump_requirements_file(
@@ -95,7 +95,7 @@ def dump_requirements_file(
     if prefixes is None:
         prefixes = set()
     elif type(prefixes) is str:
-        prefixes = set(prefixes,)
+        prefixes = set(prefixes, )
     else:
         prefixes = set(prefixes)