Formatted

Author: pcrespov

services/storage/docker/healthcheck.py

@@ -18,7 +18,6 @@
 
 import os
 import sys
-
 from urllib.request import urlopen
 
 SUCCESS, UNHEALTHY = 0, 1

services/storage/src/simcore_service_storage/__version__.py

@@ -2,7 +2,6 @@
 
 """
 import pkg_resources
-
 from semantic_version import Version
 
 __version__: str = pkg_resources.get_distribution("simcore_service_storage").version

services/storage/src/simcore_service_storage/datcore.py

@@ -14,6 +14,7 @@
 
 from blackfynn import Blackfynn
 from blackfynn.models import BaseCollection, Collection, DataPackage
+
 from simcore_service_storage.models import DatasetMetaData, FileMetaData, FileMetaDataEx
 from simcore_service_storage.settings import DATCORE_ID, DATCORE_STR
 
@@ -345,7 +346,7 @@ def download_file(self, source, filename, destination_path):
 
         url = self.download_link(source, filename)
         if url:
-            _file = urllib.URLopener() # nosec
+            _file = urllib.URLopener()  # nosec
             _file.retrieve(url, destination_path)
             return True
         return False

services/storage/src/simcore_service_storage/datcore_wrapper.py

@@ -74,9 +74,7 @@ def __init__(
             )
         except Exception:
             self.d_client = None  # Disabled: any call will raise AttributeError
-            logger.warning(
-                "Failed to setup datcore. Disabling client.", exc_info=True
-            )
+            logger.warning("Failed to setup datcore. Disabling client.", exc_info=True)
 
     @property
     def is_communication_enabled(self) -> bool:

services/storage/src/simcore_service_storage/db.py

@@ -1,6 +1,8 @@
 import logging
 
 from aiohttp import web
+from tenacity import Retrying
+
 from servicelib.aiopg_utils import (
     DataSourceName,
     PostgresRetryPolicyUponInitialization,
@@ -9,7 +11,6 @@
     is_pg_responsive,
     raise_if_not_responsive,
 )
-from tenacity import Retrying
 
 from .models import metadata
 from .settings import APP_CONFIG_KEY, APP_DB_ENGINE_KEY

services/storage/src/simcore_service_storage/dsm.py

@@ -6,7 +6,7 @@
 import tempfile
 from concurrent.futures import ThreadPoolExecutor
 from pathlib import Path
-from typing import Dict, List, Tuple, Optional
+from typing import Dict, List, Optional, Tuple
 
 import aiobotocore
 import aiofiles
@@ -44,7 +44,6 @@
     SIMCORE_S3_STR,
 )
 
-
 # pylint: disable=no-value-for-parameter
 # FIXME: E1120:No value for argument 'dml' in method call
 

services/storage/src/simcore_service_storage/models.py

@@ -9,12 +9,12 @@
 
 from simcore_postgres_database.storage_models import (
     file_meta_data,
+    groups,
     metadata,
     projects,
     tokens,
-    users,
-    groups,
     user_to_groups,
+    users,
 )
 from simcore_service_storage.settings import DATCORE_STR, SIMCORE_S3_ID, SIMCORE_S3_STR
 

services/storage/src/simcore_service_storage/rest.py

@@ -14,7 +14,6 @@
 from .resources import resources
 from .settings import APP_OPENAPI_SPECS_KEY
 
-
 log = logging.getLogger(__name__)
 
 

services/storage/src/simcore_service_storage/rest_config.py

@@ -4,6 +4,7 @@
     - settings
 """
 import trafaret as T
+
 from servicelib.config_schema_utils import minimal_addon_schema
 
 from .settings import APP_OPENAPI_SPECS_KEY

services/storage/src/simcore_service_storage/s3.py

@@ -6,9 +6,10 @@
 from typing import Dict
 
 from aiohttp import web
-from s3wrapper.s3_client import S3Client
 from tenacity import before_sleep_log, retry, stop_after_attempt, wait_fixed
 
+from s3wrapper.s3_client import S3Client
+
 from .settings import APP_CONFIG_KEY, APP_S3_KEY
 from .utils import RETRY_COUNT, RETRY_WAIT_SECS
 

services/storage/tests/test_package.py

@@ -1,14 +1,11 @@
-# TODO: W0611:Unused import ...
-# pylint: disable=W0611
-# TODO: W0613:Unused argument ...
-# pylint: disable=W0613
-# W0621: Redefining name ... from outer scope
-# pylint: disable=W0621
+# pylint:disable=unused-variable
+# pylint:disable=unused-argument
+# pylint:disable=redefined-outer-name
 
-from pytest_simcore.helpers.utils_pylint import assert_pylint_is_passing
 
 import pytest
 
+from pytest_simcore.helpers.utils_pylint import assert_pylint_is_passing
 from simcore_service_storage.cli import main
 
 

services/storage/tests/utils.py

@@ -11,10 +11,10 @@
 from simcore_service_storage.models import (
     FileMetaData,
     file_meta_data,
-    projects,
-    users,
     groups,
+    projects,
     user_to_groups,
+    users,
 )
 
 log = logging.getLogger(__name__)