Refactoring/#219 applied ptb checks and fixes

doc/changes/changes_0.1.1.md

@@ -18,3 +18,4 @@ Code name:
 * #208: Replaced access to private attribute by public
 * #203: Cleaned-up package names and directory structure
 * #217: Rename dataflow abstraction files
+* #219: Applied PTB checks and fixes

exasol/analytics/__init__.py

@@ -1 +1 @@
-__version__ = '0.1.0'
+__version__ = "0.1.0"

exasol/analytics/query_handler/context/connection_name.py

@@ -1,10 +1,7 @@
-
-from exasol.analytics.schema import (
-    DBObjectNameImpl,
-    DBObjectName,
-)
 from typeguard import typechecked
 
+from exasol.analytics.schema import DBObjectName, DBObjectNameImpl
+
 
 class ConnectionName(DBObjectName):
     """A DBObjectName class which represents the name of a connection object"""

exasol/analytics/query_handler/context/connection_name_proxy.py

@@ -1,5 +1,10 @@
-from exasol.analytics.query_handler.context.connection_name import ConnectionName, ConnectionNameImpl
-from exasol.analytics.query_handler.context.proxy.db_object_name_proxy import DBObjectNameProxy
+from exasol.analytics.query_handler.context.connection_name import (
+    ConnectionName,
+    ConnectionNameImpl,
+)
+from exasol.analytics.query_handler.context.proxy.db_object_name_proxy import (
+    DBObjectNameProxy,
+)
 from exasol.analytics.query_handler.query.drop.connection import DropConnectionQuery
 from exasol.analytics.query_handler.query.interface import Query
 

exasol/analytics/query_handler/context/proxy/bucketfs_location_proxy.py

@@ -1,8 +1,9 @@
 import logging
 
-from exasol.analytics.query_handler.context.proxy.object_proxy import ObjectProxy
 import exasol.bucketfs as bfs
 
+from exasol.analytics.query_handler.context.proxy.object_proxy import ObjectProxy
+
 LOGGER = logging.getLogger(__file__)
 
 
@@ -18,7 +19,9 @@ def bucketfs_location(self) -> bfs.path.PathLike:
 
     def cleanup(self):
         if self._not_released:
-            raise Exception("Cleanup of BucketFSLocationProxy only allowed after release.")
+            raise Exception(
+                "Cleanup of BucketFSLocationProxy only allowed after release."
+            )
         files = self._list_files()
         for file in files:
             self._remove_file(file)
@@ -33,7 +36,11 @@ def _list_files(self):
         try:
             return list(self._bucketfs_location.iterdir())
         except FileNotFoundError as e:
-            LOGGER.debug(f"File not found {self._bucketfs_location.as_udf_path} during cleanup.")
+            LOGGER.debug(
+                f"File not found {self._bucketfs_location.as_udf_path} during cleanup."
+            )
         except Exception as e:
-            LOGGER.exception(f"Got exception during listing files in temporary BucketFSLocation")
+            LOGGER.exception(
+                f"Got exception during listing files in temporary BucketFSLocation"
+            )
         return []

exasol/analytics/query_handler/context/proxy/db_object_name_proxy.py

@@ -1,14 +1,12 @@
 from abc import abstractmethod
-from typing import TypeVar, Generic
-
-from exasol.analytics.schema import DBObjectName
-
-from exasol.analytics.utils.repr_generation_for_object import generate_repr_for_object
+from typing import Generic, TypeVar
 
 from exasol.analytics.query_handler.context.proxy.object_proxy import ObjectProxy
 from exasol.analytics.query_handler.query.interface import Query
+from exasol.analytics.schema import DBObjectName
+from exasol.analytics.utils.repr_generation_for_object import generate_repr_for_object
 
-NameType = TypeVar('NameType', bound=DBObjectName)
+NameType = TypeVar("NameType", bound=DBObjectName)
 
 
 class DBObjectNameProxy(ObjectProxy, DBObjectName, Generic[NameType]):

exasol/analytics/query_handler/context/proxy/db_object_name_with_schema_proxy.py

@@ -1,16 +1,16 @@
-from typing import TypeVar, Generic
+from typing import Generic, TypeVar
 
-from exasol.analytics.schema import (
-    DBObjectNameWithSchema,
-    SchemaName,
+from exasol.analytics.query_handler.context.proxy.db_object_name_proxy import (
+    DBObjectNameProxy,
 )
+from exasol.analytics.schema import DBObjectNameWithSchema, SchemaName
 
-from exasol.analytics.query_handler.context.proxy.db_object_name_proxy import DBObjectNameProxy
+NameType = TypeVar("NameType", bound=DBObjectNameWithSchema)
 
-NameType = TypeVar('NameType', bound=DBObjectNameWithSchema)
 
-
-class DBObjectNameWithSchemaProxy(DBObjectNameProxy[NameType], DBObjectNameWithSchema, Generic[NameType]):
+class DBObjectNameWithSchemaProxy(
+    DBObjectNameProxy[NameType], DBObjectNameWithSchema, Generic[NameType]
+):
     def __init__(self, db_object_name_with_schema: NameType, global_counter_value: int):
         super().__init__(db_object_name_with_schema, global_counter_value)
 

exasol/analytics/query_handler/context/proxy/drop_udf_query.py

@@ -1,7 +1,5 @@
-from exasol.analytics.schema import UDFName
-
-
 from exasol.analytics.query_handler.query.drop.interface import DropQuery
+from exasol.analytics.schema import UDFName
 
 
 class DropUDFQuery(DropQuery):

exasol/analytics/query_handler/context/proxy/table_like_name_proxy.py

@@ -1,14 +1,16 @@
 from typing import Generic, TypeVar
 
+from exasol.analytics.query_handler.context.proxy.db_object_name_with_schema_proxy import (
+    DBObjectNameWithSchemaProxy,
+)
 from exasol.analytics.schema import TableLikeName
 
+NameType = TypeVar("NameType", bound=TableLikeName)
 
-from exasol.analytics.query_handler.context.proxy.db_object_name_with_schema_proxy import     DBObjectNameWithSchemaProxy
 
-NameType = TypeVar('NameType', bound=TableLikeName)
-
-
-class TableLikeNameProxy(DBObjectNameWithSchemaProxy[NameType], TableLikeName, Generic[NameType]):
+class TableLikeNameProxy(
+    DBObjectNameWithSchemaProxy[NameType], TableLikeName, Generic[NameType]
+):
 
     def __init__(self, table_like_name: NameType, global_counter_value: int):
         super().__init__(table_like_name, global_counter_value)

exasol/analytics/query_handler/context/proxy/table_name.py

@@ -1,9 +1,9 @@
-from exasol.analytics.schema import TableName
-
-
-from exasol.analytics.query_handler.context.proxy.table_like_name_proxy import TableLikeNameProxy
+from exasol.analytics.query_handler.context.proxy.table_like_name_proxy import (
+    TableLikeNameProxy,
+)
 from exasol.analytics.query_handler.query.drop.table import DropTableQuery
 from exasol.analytics.query_handler.query.interface import Query
+from exasol.analytics.schema import TableName
 
 
 class TableNameProxy(TableLikeNameProxy[TableName], TableName):

exasol/analytics/query_handler/context/proxy/udf_name.py

@@ -1,9 +1,9 @@
-from exasol.analytics.schema import UDFName
-
-
-from exasol.analytics.query_handler.context.proxy.db_object_name_with_schema_proxy import     DBObjectNameWithSchemaProxy
+from exasol.analytics.query_handler.context.proxy.db_object_name_with_schema_proxy import (
+    DBObjectNameWithSchemaProxy,
+)
 from exasol.analytics.query_handler.context.proxy.drop_udf_query import DropUDFQuery
 from exasol.analytics.query_handler.query.interface import Query
+from exasol.analytics.schema import UDFName
 
 
 class UDFNameProxy(DBObjectNameWithSchemaProxy[UDFName], UDFName):

exasol/analytics/query_handler/context/proxy/view_name_proxy.py

@@ -1,9 +1,9 @@
-from exasol.analytics.schema import ViewName
-
-
-from exasol.analytics.query_handler.context.proxy.table_like_name_proxy import TableLikeNameProxy
+from exasol.analytics.query_handler.context.proxy.table_like_name_proxy import (
+    TableLikeNameProxy,
+)
 from exasol.analytics.query_handler.query.drop.view import DropViewQuery
 from exasol.analytics.query_handler.query.interface import Query
+from exasol.analytics.schema import ViewName
 
 
 class ViewNameProxy(TableLikeNameProxy[ViewName], ViewName):

exasol/analytics/query_handler/context/query_handler_context.py

@@ -1,14 +1,11 @@
 import abc
 from abc import ABC
 
-from exasol.analytics.schema import (
-    TableName,
-    UDFName,
-    ViewName,
-)
-
 from exasol.analytics.query_handler.context.connection_name import ConnectionName
-from exasol.analytics.query_handler.context.proxy.bucketfs_location_proxy import     BucketFSLocationProxy
+from exasol.analytics.query_handler.context.proxy.bucketfs_location_proxy import (
+    BucketFSLocationProxy,
+)
+from exasol.analytics.schema import TableName, UDFName, ViewName
 
 
 class QueryHandlerContext(ABC):

exasol/analytics/query_handler/context/scope.py

@@ -1,8 +1,10 @@
 import enum
-from abc import abstractmethod, ABC
+from abc import ABC, abstractmethod
 
-from exasol.analytics.query_handler.context.query_handler_context import QueryHandlerContext
 from exasol.analytics.query_handler.context.proxy.object_proxy import ObjectProxy
+from exasol.analytics.query_handler.context.query_handler_context import (
+    QueryHandlerContext,
+)
 
 
 class Connection(ABC):
@@ -42,8 +44,11 @@ def get_child_query_handler_context(self) -> "ScopeQueryHandlerContext":
         pass
 
     @abstractmethod
-    def transfer_object_to(self, object_proxy: ObjectProxy,
-                           scope_query_handler_context: "ScopeQueryHandlerContext"):
+    def transfer_object_to(
+        self,
+        object_proxy: ObjectProxy,
+        scope_query_handler_context: "ScopeQueryHandlerContext",
+    ):
         """
         This function transfers the ownership of the object to a different context.
         That means, that the object isn't released if this context is released,