YATA: Yet another typing attempt.

Author: FlavioAmurrioCS

.pre-commit-config.yaml

@@ -0,0 +1,24 @@
+# See https://pre-commit.com for more information
+# See https://pre-commit.com/hooks.html for more hooks
+repos:
+  - repo: https://github.com/pre-commit/pre-commit-hooks
+    rev: v4.6.0
+    hooks:
+      # - id: trailing-whitespace
+      # - id: end-of-file-fixer
+      - id: check-yaml
+      - id: check-added-large-files
+  - repo: https://github.com/psf/black
+    rev: 24.4.2
+    hooks:
+      - id: black
+  - repo: https://github.com/pre-commit/mirrors-mypy
+    rev: v1.10.0
+    hooks:
+      - id: mypy
+        additional_dependencies: [types-tabulate]
+
+  - repo: https://github.com/astral-sh/ruff-pre-commit
+    rev: v0.4.2
+    hooks:
+      - id: ruff

docs/conf.py

@@ -11,6 +11,7 @@
 #
 # All configuration values have a default; values that are commented out
 # serve to show the default.
+from __future__ import annotations
 
 import sys
 import os

functional/__init__.py

@@ -2,7 +2,8 @@
 Package for creating data pipelines, LINQ-style data analysis, and functional programming. Imports
 the primary entrypoint at streams.seq
 """
-from functional.streams import seq, pseq
+
+from functional.streams import seq, pseq  # noqa: F401
 
 __author__ = "Pedro Rodriguez"
 __copyright__ = "Copyright 2024, Pedro Rodriguez"

functional/execution.py

@@ -2,7 +2,7 @@
 from functional.util import compose, parallelize
 
 
-class ExecutionStrategies(object):
+class ExecutionStrategies:
     """
     Enum like object listing the types of execution strategies.
     """
@@ -11,7 +11,7 @@ class ExecutionStrategies(object):
     PARALLEL = 1
 
 
-class ExecutionEngine(object):
+class ExecutionEngine:
     """
     Class to perform serial execution of a Sequence evaluation.
     """

functional/io.py

@@ -1,10 +1,11 @@
+from __future__ import annotations
 import gzip
 import lzma
 import bz2
 import io
 import builtins
 
-from typing import Optional, Generic, TypeVar, Any
+from typing import Generic, TypeVar, Any
 
 
 WRITE_MODE = "wt"
@@ -24,12 +25,12 @@ class ReusableFile(Generic[_FileConv_co]):
     def __init__(
         self,
         path: str,
-        delimiter: Optional[str] = None,
+        delimiter: str | None = None,
         mode: str = "r",
         buffering: int = -1,
-        encoding: Optional[str] = None,
-        errors: Optional[str] = None,
-        newline: Optional[str] = None,
+        encoding: str | None = None,
+        errors: str | None = None,
+        newline: str | None = None,
     ):
         """
         Constructor arguments are passed directly to builtins.open
@@ -81,19 +82,19 @@ def read(self):
 
 
 class CompressedFile(ReusableFile):
-    magic_bytes: Optional[bytes] = None
+    magic_bytes: bytes | None = None
 
     # pylint: disable=too-many-instance-attributes
     def __init__(
         self,
         path: str,
-        delimiter: Optional[str] = None,
+        delimiter: str | None = None,
         mode: str = "rt",
         buffering: int = -1,
         compresslevel: int = 9,
-        encoding: Optional[str] = None,
-        errors: Optional[str] = None,
-        newline: Optional[str] = None,
+        encoding: str | None = None,
+        errors: str | None = None,
+        newline: str | None = None,
     ):
         super(CompressedFile, self).__init__(
             path,
@@ -118,13 +119,13 @@ class GZFile(CompressedFile):
     def __init__(
         self,
         path: str,
-        delimiter: Optional[str] = None,
+        delimiter: str | None = None,
         mode: str = "rt",
         buffering: int = -1,
         compresslevel: int = 9,
-        encoding: Optional[str] = None,
-        errors: Optional[str] = None,
-        newline: Optional[str] = None,
+        encoding: str | None = None,
+        errors: str | None = None,
+        newline: str | None = None,
     ):
         super(GZFile, self).__init__(
             path,
@@ -173,13 +174,13 @@ class BZ2File(CompressedFile):
     def __init__(
         self,
         path: str,
-        delimiter: Optional[str] = None,
+        delimiter: str | None = None,
         mode: str = "rt",
         buffering: int = -1,
         compresslevel: int = 9,
-        encoding: Optional[str] = None,
-        errors: Optional[str] = None,
-        newline: Optional[str] = None,
+        encoding: str | None = None,
+        errors: str | None = None,
+        newline: str | None = None,
     ):
         super(BZ2File, self).__init__(
             path,
@@ -297,15 +298,15 @@ def universal_write_open(
     path: str,
     mode: str,
     buffering: int = -1,
-    encoding: Optional[str] = None,
-    errors: Optional[str] = None,
-    newline: Optional[str] = None,
+    encoding: str | None = None,
+    errors: str | None = None,
+    newline: str | None = None,
     compresslevel: int = 9,
-    format: Optional[int] = None,
+    format: int | None = None,
     check: int = -1,
-    preset: Optional[int] = None,
+    preset: int | None = None,
     filters: Any = None,
-    compression: Optional[str] = None,
+    compression: str | None = None,
 ):
     # pylint: disable=unexpected-keyword-arg,no-member
     if compression is None:

functional/lineage.py

@@ -2,7 +2,7 @@
 from functional.transformations import CACHE_T
 
 
-class Lineage(object):
+class Lineage:
     """
     Class for tracking the lineage of transformations, and applying them to a given sequence.
     """