Adding pre commit hooks

.github/PULL_REQUEST_TEMPLATE.md

@@ -6,7 +6,7 @@ _Summary of changes in this PR or what it accomplishes._
 
 <!--
 
-Please title your PR as follows: `feature: fix foo bar`. 
+Please title your PR as follows: `feature: fix foo bar`.
 Always start with the thing you are fixing, then describe the fix.
 Don't use past tense (e.g. "fixed foo bar").
 

.pre-commit-config.yaml

@@ -1,13 +1,32 @@
 # 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: v2.3.0
+    hooks:
+      # - id: check-yaml
+      - id: end-of-file-fixer
+      - id: trailing-whitespace
+      - id: mixed-line-ending
+      - id: check-added-large-files
+  - repo: https://github.com/pycqa/flake8
+    rev: 6.1.0
+    hooks:
+      - id: flake8
+        additional_dependencies: [flake8-black, flake8-bugbear, flake8-isort]
+  - repo: https://github.com/pycqa/isort
+    rev: 5.13.2
+    hooks:
+      - id: isort
+        name: isort (python)
+      - id: isort
+        name: isort (cython)
+        types: [cython]
+      - id: isort
+        name: isort (pyi)
+        types: [pyi]
   - repo: https://github.com/ambv/black
     rev: 23.1.0
     hooks:
       - id: black
         language_version: python3
-  - repo: https://github.com/pycqa/flake8
-    rev: 6.0.0
-    hooks:
-      - id: flake8
-        additional_dependencies: [flake8-black, flake8-bugbear]

.python-version

@@ -1 +1 @@
-3.10.10
+3.10.13

Pipfile

@@ -17,6 +17,7 @@ flake8-bugbear = "*"
 black = "*"
 localstack = "*"
 awscli-local = "*"
+pre-commit = "*"
 
 [requires]
 python_version = "3.10"

jobs/etl/__init__.py

@@ -1,4 +1,4 @@
 from .extract import extract
-from .load_postgresql import load_to_postgresql_db
 from .load_documentdb import load_to_document_db
+from .load_postgresql import load_to_postgresql_db
 from .load_s3 import load_to_s3

jobs/etl/extract.py

@@ -1,9 +1,10 @@
 from typing import List
+
 from awsglue.context import GlueContext
 
 from jobs.io import read_from_options
-from libs.config import Config
 from libs.aws import AwsS3Client
+from libs.config import Config
 
 
 def extract(glueContext: GlueContext, config: Config):

jobs/etl/load_s3.py

@@ -1,4 +1,5 @@
-from awsglue.context import GlueContext, DynamicFrame
+from awsglue.context import DynamicFrame, GlueContext
+
 from jobs.io.writer import write_from_options
 from libs.config import Config
 

jobs/io/__init__.py

@@ -1,3 +1,3 @@
+from .helpers import get_connection_options
 from .reader import read_from_options
 from .writer import write_from_options
-from .helpers import get_connection_options

jobs/io/helpers.py

@@ -1,5 +1,6 @@
-from typing import Dict, Tuple, Union
+from typing import Dict, Optional, Tuple, Union
 from urllib.parse import quote
+
 from libs.common import load_tls_ca_bundle
 
 
@@ -8,8 +9,8 @@ def get_url_for_engine(
     port: int,
     database: str,
     engine: str,
-    user: str = None,
-    password: str = None,
+    user: Optional[str] = None,
+    password: Optional[str] = None,
     ssl: bool = False,
 ) -> str:
     """
@@ -44,8 +45,8 @@ def _build_mongodb_connection_string(
     port: int,
     database: str,
     engine: str,
-    user: str = None,
-    password: str = None,
+    user: Optional[str] = None,
+    password: Optional[str] = None,
     ssl: Union[bool, str] = False,
 ):
     encoded_user = _encode_mongodb_auth_special_chars(user)
@@ -61,7 +62,7 @@ def _build_mongodb_connection_string(
     return url
 
 
-def _encode_mongodb_auth_special_chars(authchars: str):
+def _encode_mongodb_auth_special_chars(authchars: Optional[str] = None):
     """
     This is a helper function to encode special characters
     that might be present on user, password, tokens, etc:
@@ -108,7 +109,7 @@ def get_connection_type(engine: str, ssl: bool = False) -> str:
     return connection_type
 
 
-def get_driver_for_engine(engine: str = None) -> str:
+def get_driver_for_engine(engine: Optional[str] = None) -> str:
     """
     Returns the driver for the engine
 
@@ -128,7 +129,7 @@ def get_driver_for_engine(engine: str = None) -> str:
     return drivers[engine]
 
 
-def get_format_for_engine(engine: str = None) -> str:
+def get_format_for_engine(engine: Optional[str] = None) -> str:
     """
     Returns the format for the engine
 
@@ -150,21 +151,21 @@ def get_format_for_engine(engine: str = None) -> str:
 
 def get_connection_options(
     engine: str,
-    host: str = None,
-    port: int = None,
-    database: str = None,
-    user: str = None,
-    password: str = None,
+    host: str,
+    port: int,
+    database: str,
+    user: Optional[str],
+    password: Optional[str],
+    dbtable: Optional[str],
+    collection: Optional[str],
+    aws_access_key_id: Optional[str],
+    aws_secret_access_key: Optional[str],
+    aws_region_name: Optional[str],
+    aws_session_token: Optional[str],
+    aws_endpoint_url: Optional[str],
+    paths: Optional[str],
+    path: Optional[str],
     ssl: bool = False,
-    dbtable: str = None,
-    collection: str = None,
-    aws_access_key_id: str = None,
-    aws_secret_access_key: str = None,
-    aws_region_name: str = None,
-    aws_session_token: str = None,
-    aws_endpoint_url: str = None,
-    paths: str = None,
-    path: str = None,
 ) -> Tuple[str, str, Dict[str, str]]:
     """
     Returns the format and options for the engine. Will use the AWS credentials
@@ -176,7 +177,6 @@ def get_connection_options(
     :param engine: The engine to get the format and options for
     :param user: The user to connect with
     :param password: The password to connect with
-    :param ssl: Whether to use ssl or not
     :param dbtable: The table to connect to
     :param collection: The collection to connect to
     :param aws_access_key_id: The aws access key id to connect with
@@ -185,6 +185,7 @@ def get_connection_options(
     :param aws_session_token: The aws session token to connect with
     :param aws_endpoint_url: The aws endpoint url to connect with
     :param path: The path to connect to
+    :param ssl: Whether to use ssl or not
     :return: The format and options for the engine
     """
     if engine is None:

jobs/io/reader.py

@@ -1,4 +1,5 @@
-from awsglue.context import GlueContext, DynamicFrame
+from awsglue.context import DynamicFrame, GlueContext
+
 from .helpers import get_connection_options
 
 

jobs/io/writer.py

@@ -1,4 +1,5 @@
-from awsglue.context import GlueContext, DynamicFrame
+from awsglue.context import DynamicFrame, GlueContext
+
 from .helpers import get_connection_options
 
 

jobs/pyspark_hello_world.py

@@ -1,11 +1,13 @@
 import sys
 
-from awsglue.utils import getResolvedOptions
-from pyspark.context import SparkContext
 from awsglue.context import GlueContext
 from awsglue.job import Job
+from awsglue.utils import getResolvedOptions
+from pyspark.context import SparkContext
+
+from jobs.etl import extract, load_to_postgresql_db, load_to_s3
 
-from jobs.etl import extract, load_to_s3, load_to_postgresql_db, load_to_document_db
+# from jobs.etl import load_to_document_db # isort: skip_file
 from libs.config import get_config
 
 args = getResolvedOptions(sys.argv, ["JOB_NAME"])

libs/aws/s3.py

@@ -1,5 +1,7 @@
 from typing import Union
+
 import boto3
+
 from libs.config import get_config
 
 

libs/common/__init__.py

@@ -1,2 +1,2 @@
-from .util import cached_property
 from .perm import load_tls_ca_bundle
+from .util import cached_property

libs/config/__init__.py

@@ -1 +1 @@
-from .config import get_config, Config
+from .config import Config, get_config

libs/config/env.py

@@ -10,7 +10,7 @@ class EnvironmentVariable:
     args = {}
     cache = {}
 
-    def __init__(self, args: dict = None) -> None:
+    def __init__(self, args: dict = None) -> None:  # type: ignore
         if args is None:
             args = dict()
         self.args = args
@@ -38,7 +38,7 @@ def get_var(self, key, default: Any = None, throw_error: bool = False) -> Any:
 envs_instance = None
 
 
-def get_envs(args: dict = None) -> EnvironmentVariable:
+def get_envs(args: dict = None) -> EnvironmentVariable:  # type: ignore
     """
     Get the envs instance. If it doesn't exist, create it.
 

libs/config/secrets.py

@@ -1,7 +1,9 @@
 from __future__ import annotations
-import boto3
+
 import base64
 import json
+
+import boto3
 from botocore.exceptions import ClientError
 
 secrets_resolver_instance = None

libs/db/docdb_mongo.py

@@ -1,5 +1,7 @@
-from libs.common import load_tls_ca_bundle
 from pymongo import MongoClient as PyMongoClient
+
+from libs.common import load_tls_ca_bundle
+
 from .mongo import MongoClient
 
 

libs/db/mongo.py

@@ -1,6 +1,8 @@
-from typing import Any, Dict, List, Tuple, Union
+from typing import Any, Dict, List, Optional, Tuple, Union
+
 from pymongo import MongoClient as PyMongoClient
-from libs.common.logconfig import LogConfig
+
+from libs.common.logconfig import LogConfig  # type: ignore
 
 
 class MongoClient:
@@ -14,7 +16,7 @@ def __init__(
         port: int,
         database: str,
         protocol: str = "mongodb",
-        collection: str = None,
+        collection: str = None,  # type: ignore
         throw_error: bool = True,
     ) -> None:
         connection_uri = (
@@ -32,7 +34,7 @@ def __init__(
 
         if self._conn is None and throw_error:
             raise Exception(
-                "Could not connect to " + host + ":" + port + " was not found."
+                f"Could not connect to {host}:{port} with user {user} and password {password}"
             )
 
         self._db = self._conn[database]
@@ -71,7 +73,7 @@ def find_sorted_limit(
         query: Dict[str, Any],
         sort: List[Tuple[str, int]],
         limit: int,
-        projection: Dict[str, Any] = None,
+        projection: Dict[str, Any] = None,  # type: ignore
     ) -> List[Dict[str, Any]]:
         return list(self._collection.find(query, projection).sort(sort).limit(limit))
 
@@ -81,20 +83,15 @@ def find_sorted_limit_skip(
         sort: List[Tuple[str, int]],
         limit: int,
         skip: int,
-        projection: Dict[str, Any] = None,
+        projection: Dict[str, Any] = None,  # type: ignore
     ) -> List[Dict[str, Any]]:
         return list(
             self._collection.find(query, projection).sort(sort).limit(limit).skip(skip)
         )
 
-    def find_one(self, query: Dict[str, Any]) -> Dict[str, Any]:
+    def find_one(self, query: Dict[str, Any]) -> Optional[Dict[str, Any]]:
         return self._collection.find_one(query)
 
-    def find_one_and_update(
-        self, query: Dict[str, Any], update: Dict[str, Any]
-    ) -> Dict[str, Any]:
-        return self._collection.find_one_and_update(query, update)
-
     def find_one_and_delete(self, query: Dict[str, Any]) -> Dict[str, Any]:
         return self._collection.find_one_and_delete(query)