Update metrics tracker decorator

sns_sqs_communicator/metrics.py

@@ -5,24 +5,27 @@
 import os
 import typing
 
+FP = typing.ParamSpec("FP")  # Function Parameters
+RV = typing.TypeVar("RV")  # Returned Value
+
 
 def tracker(
-    func: collections.abc.Callable[..., typing.Any],
-) -> typing.Any:
+    func: collections.abc.Callable[FP, RV],
+) -> collections.abc.Callable[FP, RV]:
     """Create a placeholder for performance tracker."""
 
     @functools.wraps(func)
     def wrapper_tracker(
-        *args: typing.Any,
-        **kwargs: typing.Any,
-    ) -> typing.Any:
+        *args: FP.args,
+        **kwargs: FP.kwargs,
+    ) -> RV:
         return func(*args, **kwargs)
 
     return wrapper_tracker
 
 
 with contextlib.suppress(KeyError):  # pragma: no cover
-    metric_tracker_path = os.environ["SNS_SQS_COMMUNICATOR_METRIC_TRACKER"]
+    metric_tracker_path = os.environ["FASTAPI_REST_FRAMEWORK_METRIC_TRACKER"]
     *module, tracker_name = metric_tracker_path.split(".")
     tracker = getattr(importlib.import_module(".".join(module)), tracker_name)  # noqa: F811
 

sns_sqs_communicator/sqs_poll_worker.py

@@ -225,7 +225,7 @@ async def handle_processing_error(
         cls,
         raw_message: mypy_boto3_sqs.type_defs.MessageTypeDef,
         error: Exception,
-        parser: parsers.ParserProtocol[messages.MessageActionT],
+        parser: type[parsers.ParserProtocol[messages.MessageActionT]],
         dead_letter_queue: queue.SQSQueue,
         logger: logging.Logger,
     ) -> None: