flake8

Author: saimonation

cterasdk/asynchronous/core/invitation/login.py

@@ -10,7 +10,7 @@ class Login(BaseCommand):
     Portal Login APIs
     """
 
-    async def login(self, key, value):  #pylint: disable=unused-argument
+    async def login(self, key, value):
         logger.info('Creating external session. %s', {'invite': value})
         await self._core.clients.v1.ctera.get('', params={key: value})
 

cterasdk/cio/core/commands.py

@@ -696,7 +696,6 @@ async def _a_execute(self):
     def _suppress_file_conflict_error(e):
         if not isinstance(e.__cause__, exceptions.io.core.FileConflictError):
             raise e
-        
 
     def _handle_response(self, r):
         path = self.path.relative

cterasdk/cio/core/types.py

@@ -110,7 +110,7 @@ class InvitationPath(PortalPath):
     Invitation Path Object
     """
     Namespace = '/invitations/webdav'
-    expr = f'{Namespace}/share\/([a-zA-Z0-9]+)'
+    expr = f'{Namespace}/share/([a-zA-Z0-9]+)'
 
     @staticmethod
     def from_context(reference):

cterasdk/cli/dav.py

@@ -48,7 +48,7 @@ async def handle_download(args):
     target = Path(args.dest or os.getcwd())
 
     try:
-    
+
         Path.mkdir(target, exist_ok=True)
 
         async def download(invitation, resource, objects=None, archive=False, destination=None):
@@ -81,7 +81,7 @@ async def download(invitation, resource, objects=None, archive=False, destinatio
                                     await asynfs.mkdir(target.joinpath(r.path.relative), parents=True, exist_ok=True)
                                 else:
                                     jobs.append(download(invitation, r, destination=target))
-                except (GetMetadataError, ListDirectoryError) as e:
+                except (GetMetadataError, ListDirectoryError):
                     print(f"error: failed to obtain properties or list a directory: '{args.src}'", file=sys.stderr)
                     sys.exit(1)
 
@@ -104,7 +104,7 @@ async def handle_upload(args):
 
     async with AsyncInvitation.from_uri(args.endpoint) as invitation:
         if not invitation.details.is_dir:
-            print(f"error: destination is not a directory", file=sys.stderr)
+            print("error: destination is not a directory", file=sys.stderr)
             sys.exit(1)
         elif invitation.details.access not in [FileAccessMode.RW, FileAccessMode.UO]:
             print(f"error: insufficient permissions to write to: {args.dest}", file=sys.stderr)
@@ -159,4 +159,4 @@ async def main():
 
 
 def webdav():
-    asyncio.run(main())
+    asyncio.run(main())

cterasdk/core/invitation/login.py

@@ -1,6 +1,5 @@
 import logging
 from ..base_command import BaseCommand
-from ...exceptions.transport import InternalServerError
 
 
 logger = logging.getLogger('cterasdk.core')
@@ -11,7 +10,7 @@ class Login(BaseCommand):
     Portal Login APIs
     """
 
-    def login(self, key, value):  #pylint: disable=unused-argument
+    def login(self, key, value):
         logger.info('Creating external session. %s', {'invite': value})
         self._core.clients.ctera.get('', params={key: value})
 

cterasdk/lib/session/core.py

@@ -63,7 +63,7 @@ async def _async_start_session(self, session):
             software_version = session.v1.api.get('/version')
             authorizations = await session.roles.get(user_session.role) if user_session.role in Administrators else None
             account = PortalUser(user_session.username, user_session.domain, await current_tenant or Session.Administration,
-                                user_session.role, authorizations)
+                                 user_session.role, authorizations)
             self._update_software_version(await software_version)
         else:
             account = ExternalUser()

cterasdk/lib/storage/asynfs.py

@@ -56,5 +56,5 @@ async def mkdir(p, parents=False, exist_ok=True):
         await aiofiles.os.makedirs(location, exist_ok=exist_ok)
     else:
         await aiofiles.os.mkdir(location, exist_ok=exist_ok)
-        
+
     return location.as_posix()

cterasdk/lib/storage/synfs.py

@@ -1,5 +1,4 @@
 import logging
-from pathlib import Path
 from .commonfs import write_new_version, ResultContext, expanduser
 
 

cterasdk/objects/asynchronous/invitation.py

@@ -15,17 +15,20 @@ async def __aenter__(self):
     def __init__(self, host, port, invite):
         super().__init__(host, port)
         self.invite = invite
-        self.clients.v1.api = self.default.clone(clients.AsyncAPI, EndpointBuilder.new(self.base, self.context, f'/portalInvitation/share/{invite}'))
-        self.clients.io._webdav = self.default.clone(clients.AsyncWebDAV, EndpointBuilder.new(self.base, self.context, f'/webdav/share/{invite}'))
-        self.clients.io._upload = self.default.clone(clients.AsyncUpload, EndpointBuilder.new(self.base, self.context, f'/upload/share/{invite}'))
+        self.clients.v1.api = self.default.clone(clients.AsyncAPI, EndpointBuilder.new(self.base,
+                                                                                       self.context, f'/portalInvitation/share/{invite}'))
+        self.clients.io._webdav = self.default.clone(clients.AsyncWebDAV, EndpointBuilder.new(self.base,
+                                                                                              self.context, f'/webdav/share/{invite}'))
+        self.clients.io._upload = self.default.clone(clients.AsyncUpload, EndpointBuilder.new(self.base,
+                                                                                              self.context, f'/upload/share/{invite}'))
         self.files = files.InvitationBrowser(self)
         self.details = None
 
     @property
     def context(self):
         return 'invitations'
 
-    def _authenticator(self, url):  #pylint: disable=unused-argument
+    def _authenticator(self, url):  # pylint: disable=unused-argument
         return True
 
     async def login(self):
@@ -47,4 +50,4 @@ def from_uri(uri):
 
     async def __aexit__(self, exc_type, exc, tb):
         await self.logout()
-        return await super().__aexit__(exc_type, exc, tb)
+        return await super().__aexit__(exc_type, exc, tb)

cterasdk/objects/invitation.py

@@ -22,4 +22,4 @@ def validate(uri):
 
 
 def uri(invitation):
-    return f'{invitation.clients.ctera.baseurl}/?share={invitation.invite}'
+    return f'{invitation.clients.ctera.baseurl}/?share={invitation.invite}'