Lint: Fix pyright errors in s3 module

Author: ByteOtter

src/gardenlinux/s3/__main__.py

@@ -6,12 +6,6 @@
 """
 
 import argparse
-import os
-import re
-import sys
-from functools import reduce
-from pathlib import Path
-from typing import Any, List, Set
 
 from .s3_artifacts import S3Artifacts
 

src/gardenlinux/s3/bucket.py

@@ -56,7 +56,7 @@ def __init__(
         if endpoint_url is not None:
             s3_resource_config["endpoint_url"] = endpoint_url
 
-        self._s3_resource = boto3.resource("s3", **s3_resource_config)
+        self._s3_resource: Any = boto3.resource("s3", **s3_resource_config)
 
         self._bucket = self._s3_resource.Bucket(bucket_name)
         self._logger = logger
@@ -116,7 +116,9 @@ def download_fileobj(self, key, fp, *args, **kwargs):
 
         self._logger.info(f"Downloaded {key} from S3 as binary data")
 
-    def read_cache_file_or_filter(self, cache_file, cache_ttl: int = 3600, **kwargs):
+    def read_cache_file_or_filter(
+        self, cache_file: str | PathLike[str] | None, cache_ttl: int = 3600, **kwargs
+    ):
         """
         Read S3 object keys from cache if valid or filter for S3 object keys.
 
@@ -128,19 +130,24 @@ def read_cache_file_or_filter(self, cache_file, cache_ttl: int = 3600, **kwargs)
         :since: 0.9.0
         """
 
-        if not isinstance(cache_file, PathLike):
-            cache_file = Path(cache_file)
+        if cache_file is not None:
+            cache_path = Path(cache_file)
 
-        if cache_file.exists() and (time() - cache_file.stat().st_mtime) < cache_ttl:
-            with cache_file.open("r") as fp:
-                return json.loads(fp.read())
+            if (
+                cache_path.exists()
+                and (time() - cache_path.stat().st_mtime) < cache_ttl
+            ):
+                with cache_path.open("r") as fp:
+                    return json.loads(fp.read())
+        else:
+            cache_path = None
 
         artifacts = [
             s3_object.key for s3_object in self._bucket.objects.filter(**kwargs).all()
         ]
 
-        if cache_file is not None:
-            with cache_file.open("w") as fp:
+        if cache_path is not None:
+            with cache_path.open("w") as fp:
                 fp.write(json.dumps(artifacts))
 
         return artifacts

src/gardenlinux/s3/s3_artifacts.py

@@ -18,7 +18,6 @@
 import yaml
 
 from ..features.cname import CName
-from ..logger import LoggerSetup
 from .bucket import Bucket
 
 
@@ -53,7 +52,7 @@ def __init__(
         :since: 0.8.0
         """
 
-        self._bucket = Bucket(bucket_name, endpoint_url, s3_resource_config)
+        self._bucket = Bucket(bucket_name, endpoint_url, s3_resource_config, logger)
 
     @property
     def bucket(self):
@@ -68,8 +67,8 @@ def bucket(self):
 
     def download_to_directory(
         self,
-        cname,
-        artifacts_dir,
+        cname: str,
+        artifacts_dir: str | PathLike[str],
     ):
         """
         Download S3 artifacts to a given directory.
@@ -80,8 +79,7 @@ def download_to_directory(
         :since: 0.8.0
         """
 
-        if not isinstance(artifacts_dir, PathLike):
-            artifacts_dir = Path(artifacts_dir)
+        artifacts_dir = Path(artifacts_dir)
 
         if not artifacts_dir.is_dir():
             raise RuntimeError(f"Artifacts directory given is invalid: {artifacts_dir}")
@@ -101,8 +99,8 @@ def download_to_directory(
 
     def upload_from_directory(
         self,
-        cname,
-        artifacts_dir,
+        cname: str,
+        artifacts_dir: str | PathLike[str],
         delete_before_push=False,
     ):
         """
@@ -115,8 +113,7 @@ def upload_from_directory(
         :since: 0.8.0
         """
 
-        if not isinstance(artifacts_dir, PathLike):
-            artifacts_dir = Path(artifacts_dir)
+        artifacts_dir = Path(artifacts_dir)
 
         cname_object = CName(cname)
 
@@ -146,6 +143,9 @@ def upload_from_directory(
                 f"Release file data and given cname conflict detected: Commit ID {cname_object.commit_id}"
             )
 
+        if cname_object.version is None:
+            raise RuntimeError("CName version could not be determined!")
+
         commit_hash = release_config.get(UNNAMED_SECTION, "GARDENLINUX_COMMIT_ID_LONG")
 
         feature_set = release_config.get(UNNAMED_SECTION, "GARDENLINUX_FEATURES")