diff --git a/README.md b/README.md
index cfbb6dc1..4f80f042 100644
--- a/README.md
+++ b/README.md
@@ -75,6 +75,7 @@ if __name__ == "__main__":
 - [ ] Store (kafka streams pattern)
 - [ ] Stream Join
 - [ ] Windowing
+- [ ] PEP 593
 
 ## Development
 
diff --git a/kstreams/__init__.py b/kstreams/__init__.py
index 54e82471..c8b045eb 100644
--- a/kstreams/__init__.py
+++ b/kstreams/__init__.py
@@ -1,5 +1,7 @@
 from aiokafka.structs import RecordMetadata, TopicPartition
 
+from ._di.parameters import FromHeader, Header
+from .backends.kafka import Kafka
 from .clients import Consumer, Producer
 from .create import StreamEngine, create_engine
 from .prometheus.monitor import PrometheusMonitor, PrometheusMonitorType
@@ -31,4 +33,8 @@
     "TestStreamClient",
     "TopicPartition",
     "TopicPartitionOffset",
+    "Kafka",
+    "StreamDependencyManager",
+    "FromHeader",
+    "Header",
 ]
diff --git a/kstreams/_di/binders/api.py b/kstreams/_di/binders/api.py
new file mode 100644
index 00000000..02b959e8
--- /dev/null
+++ b/kstreams/_di/binders/api.py
@@ -0,0 +1,68 @@
+import inspect
+from typing import Any, AsyncIterator, Awaitable, Protocol, TypeVar, Union
+
+from di.api.dependencies import CacheKey
+from di.dependent import Dependent, Marker
+
+from kstreams.types import ConsumerRecord
+
+
+class ExtractorTrait(Protocol):
+    """Implement to extract data from incoming `ConsumerRecord`.
+
+    Consumers will always work with a consumer Record.
+    Implementing this would let you extract information from the `ConsumerRecord`.
+    """
+
+    def __hash__(self) -> int:
+        """Required by di in order to cache the deps"""
+        ...
+
+    def __eq__(self, __o: object) -> bool:
+        """Required by di in order to cache the deps"""
+        ...
+
+    async def extract(
+        self, consumer_record: ConsumerRecord
+    ) -> Union[Awaitable[Any], AsyncIterator[Any]]:
+        """This is where the magic should happen.
+
+        For example, you could "extract" here a json from the `ConsumerRecord.value`
+        """
+        ...
+
+
+T = TypeVar("T", covariant=True)
+
+
+class MarkerTrait(Protocol[T]):
+    def register_parameter(self, param: inspect.Parameter) -> T: ...
+
+
+class Binder(Dependent[Any]):
+    def __init__(
+        self,
+        *,
+        extractor: ExtractorTrait,
+    ) -> None:
+        super().__init__(call=extractor.extract, scope="consumer_record")
+        self.extractor = extractor
+
+    @property
+    def cache_key(self) -> CacheKey:
+        return self.extractor
+
+
+class BinderMarker(Marker):
+    """Bind together the different dependencies.
+
+    NETX: Add asyncapi marker here, like `MarkerTrait[AsyncApiTrait]`.
+        Recommendation to wait until 3.0:
+            - [#618](https://github.com/asyncapi/spec/issues/618)
+    """
+
+    def __init__(self, *, extractor_marker: MarkerTrait[ExtractorTrait]) -> None:
+        self.extractor_marker = extractor_marker
+
+    def register_parameter(self, param: inspect.Parameter) -> Binder:
+        return Binder(extractor=self.extractor_marker.register_parameter(param))
diff --git a/kstreams/_di/binders/header.py b/kstreams/_di/binders/header.py
new file mode 100644
index 00000000..c0f46de6
--- /dev/null
+++ b/kstreams/_di/binders/header.py
@@ -0,0 +1,44 @@
+import inspect
+from typing import Any, NamedTuple, Optional
+
+from kstreams.exceptions import HeaderNotFound
+from kstreams.types import ConsumerRecord
+
+
+class HeaderExtractor(NamedTuple):
+    name: str
+
+    def __hash__(self) -> int:
+        return hash((self.__class__, self.name))
+
+    def __eq__(self, __o: object) -> bool:
+        return isinstance(__o, HeaderExtractor) and __o.name == self.name
+
+    async def extract(self, consumer_record: ConsumerRecord) -> Any:
+        headers = dict(consumer_record.headers)
+        try:
+            header = headers[self.name]
+        except KeyError as e:
+            message = (
+                f"No header `{self.name}` found.\n"
+                "Check if your broker is sending the header.\n"
+                "Try adding a default value to your parameter like `None`.\n"
+                "Or set `convert_underscores = False`."
+            )
+            raise HeaderNotFound(message) from e
+        else:
+            return header
+
+
+class HeaderMarker(NamedTuple):
+    alias: Optional[str]
+    convert_underscores: bool
+
+    def register_parameter(self, param: inspect.Parameter) -> HeaderExtractor:
+        if self.alias is not None:
+            name = self.alias
+        elif self.convert_underscores:
+            name = param.name.replace("_", "-")
+        else:
+            name = param.name
+        return HeaderExtractor(name=name)
diff --git a/kstreams/_di/dependencies/core.py b/kstreams/_di/dependencies/core.py
new file mode 100644
index 00000000..310638d4
--- /dev/null
+++ b/kstreams/_di/dependencies/core.py
@@ -0,0 +1,114 @@
+from typing import Any, Callable, Optional
+
+from di import Container, bind_by_type
+from di.dependent import Dependent
+from di.executors import AsyncExecutor
+
+from kstreams._di.dependencies.hooks import bind_by_generic
+from kstreams.streams import Stream
+from kstreams.types import ConsumerRecord, Send
+
+LayerFn = Callable[..., Any]
+
+
+class StreamDependencyManager:
+    """Core of dependency injection on kstreams.
+
+    This is an internal class of kstreams that manages the dependency injection,
+    as a user you should not use this class directly.
+
+    Attributes:
+        container: dependency store.
+        stream: the stream wrapping the user function. Optional to improve testability.
+            When instanciating this class you must provide a stream, otherwise users
+            won't be able to use the `stream` parameter in their functions.
+        send: send object. Optional to improve testability, same as stream.
+
+    Usage:
+
+    stream and send are ommited for simplicity
+
+    ```python
+    def user_func(cr: ConsumerRecord):
+        ...
+
+    sdm = StreamDependencyManager()
+    sdm.solve(user_func)
+    sdm.execute(consumer_record)
+    ```
+    """
+
+    container: Container
+
+    def __init__(
+        self,
+        container: Optional[Container] = None,
+        stream: Optional[Stream] = None,
+        send: Optional[Send] = None,
+    ):
+        self.container = container or Container()
+        self.async_executor = AsyncExecutor()
+        self.stream = stream
+        self.send = send
+
+    def solve_user_fn(self, fn: LayerFn) -> None:
+        """Build the dependency graph for the given function.
+
+        Objects must be injected before this function is called.
+
+        Attributes:
+            fn: user defined function, using allowed kstreams params
+        """
+        self._register_consumer_record()
+
+        if isinstance(self.stream, Stream):
+            self._register_stream(self.stream)
+
+        if self.send is not None:
+            self._register_send(self.send)
+
+        self.solved_user_fn = self.container.solve(
+            Dependent(fn, scope="consumer_record"),
+            scopes=["consumer_record", "stream", "application"],
+        )
+
+    async def execute(self, consumer_record: ConsumerRecord) -> Any:
+        """Execute the dependencies graph with external values.
+
+        Attributes:
+            consumer_record: A kafka record containing `values`, `headers`, etc.
+        """
+        async with self.container.enter_scope("consumer_record") as state:
+            return await self.container.execute_async(
+                self.solved_user_fn,
+                values={ConsumerRecord: consumer_record},
+                executor=self.async_executor,
+                state=state,
+            )
+
+    def _register_stream(self, stream: Stream):
+        """Register the stream with the container."""
+        hook = bind_by_type(
+            Dependent(lambda: stream, scope="consumer_record", wire=False), Stream
+        )
+        self.container.bind(hook)
+
+    def _register_consumer_record(self):
+        """Register consumer record with the container.
+
+        We bind_by_generic because we want to bind the `ConsumerRecord` type which
+        is generic.
+
+        The value must be injected at runtime.
+        """
+        hook = bind_by_generic(
+            Dependent(ConsumerRecord, scope="consumer_record", wire=False),
+            ConsumerRecord,
+        )
+        self.container.bind(hook)
+
+    def _register_send(self, send: Send):
+        hook = bind_by_type(
+            Dependent(lambda: send, scope="consumer_record", wire=False), Send
+        )
+        self.container.bind(hook)
diff --git a/kstreams/_di/dependencies/hooks.py b/kstreams/_di/dependencies/hooks.py
new file mode 100644
index 00000000..11e0799e
--- /dev/null
+++ b/kstreams/_di/dependencies/hooks.py
@@ -0,0 +1,31 @@
+import inspect
+from typing import Any, get_origin
+
+from di._container import BindHook
+from di._utils.inspect import get_type
+from di.api.dependencies import DependentBase
+
+
+def bind_by_generic(
+    provider: DependentBase[Any],
+    dependency: type,
+) -> BindHook:
+    """Hook to substitute the matched dependency based on its generic."""
+
+    def hook(
+        param: inspect.Parameter | None, dependent: DependentBase[Any]
+    ) -> DependentBase[Any] | None:
+        if dependent.call == dependency:
+            return provider
+        if param is None:
+            return None
+
+        type_annotation_option = get_type(param)
+        if type_annotation_option is None:
+            return None
+        type_annotation = type_annotation_option.value
+        if get_origin(type_annotation) is dependency:
+            return provider
+        return None
+
+    return hook
diff --git a/kstreams/_di/parameters.py b/kstreams/_di/parameters.py
new file mode 100644
index 00000000..b16a1b1e
--- /dev/null
+++ b/kstreams/_di/parameters.py
@@ -0,0 +1,37 @@
+from typing import Optional, TypeVar
+
+from kstreams._di.binders.api import BinderMarker
+from kstreams._di.binders.header import HeaderMarker
+from kstreams.typing import Annotated
+
+
+def Header(
+    *, alias: Optional[str] = None, convert_underscores: bool = True
+) -> BinderMarker:
+    """Construct another type from the headers of a kafka record.
+
+    Args:
+        alias: Use a different header name
+        convert_underscores: If True, convert underscores to dashes.
+
+    Usage:
+
+    ```python
+    from kstream import Header, Annotated
+
+    def user_fn(event_type: Annotated[str, Header(alias="EventType")]):
+        ...
+    ```
+    """
+    header_marker = HeaderMarker(alias=alias, convert_underscores=convert_underscores)
+    binder = BinderMarker(extractor_marker=header_marker)
+    return binder
+
+
+T = TypeVar("T")
+
+FromHeader = Annotated[T, Header()]
+FromHeader.__doc__ = """General purpose convenient header type.
+
+Use `Annotated` to provide custom params.
+"""
diff --git a/kstreams/engine.py b/kstreams/engine.py
index b69095f6..5b8b9057 100644
--- a/kstreams/engine.py
+++ b/kstreams/engine.py
@@ -5,13 +5,13 @@
 
 from aiokafka.structs import RecordMetadata
 
+from kstreams.middleware.di_middleware import DependencyInjectionHandler
 from kstreams.structs import TopicPartitionOffset
 
 from .backends.kafka import Kafka
 from .clients import Consumer, Producer
 from .exceptions import DuplicateStreamException, EngineNotStartedException
 from .middleware import Middleware
-from .middleware.udf_middleware import UdfHandler
 from .prometheus.monitor import PrometheusMonitor
 from .rebalance_listener import MetricsRebalanceListener, RebalanceListener
 from .serializers import Deserializer, Serializer
@@ -389,7 +389,13 @@ def add_stream(
         stream.rebalance_listener.stream = stream
         stream.rebalance_listener.engine = self
 
-        stream.udf_handler = UdfHandler(
+        # stream.udf_handler = UdfHandler(
+        #     next_call=stream.func,
+        #     send=self.send,
+        #     stream=stream,
+        # )
+
+        stream.udf_handler = DependencyInjectionHandler(
             next_call=stream.func,
             send=self.send,
             stream=stream,
@@ -397,7 +403,7 @@ def add_stream(
 
         # NOTE: When `no typing` support is deprecated this check can
         # be removed
-        if stream.udf_handler.type != UDFType.NO_TYPING:
+        if stream.udf_handler.get_type() != UDFType.NO_TYPING:
             stream.func = self._build_stream_middleware_stack(stream=stream)
 
     def _build_stream_middleware_stack(self, *, stream: Stream) -> NextMiddlewareCall:
diff --git a/kstreams/exceptions.py b/kstreams/exceptions.py
index 249f2db7..dd5a65d9 100644
--- a/kstreams/exceptions.py
+++ b/kstreams/exceptions.py
@@ -25,3 +25,6 @@ def __str__(self) -> str:
 
 
 class BackendNotSet(StreamException): ...
+
+
+class HeaderNotFound(StreamException): ...
diff --git a/kstreams/middleware/di_middleware.py b/kstreams/middleware/di_middleware.py
new file mode 100644
index 00000000..2e53f5ad
--- /dev/null
+++ b/kstreams/middleware/di_middleware.py
@@ -0,0 +1,30 @@
+import inspect
+import typing
+
+from kstreams import types
+from kstreams._di.dependencies.core import StreamDependencyManager
+from kstreams.streams_utils import UDFType, setup_type
+
+from .middleware import BaseMiddleware
+
+
+class DependencyInjectionHandler(BaseMiddleware):
+    def __init__(self, *args, **kwargs) -> None:
+        super().__init__(*args, **kwargs)
+
+        self.dependecy_manager = StreamDependencyManager(
+            stream=self.stream, send=self.send
+        )
+
+        # To be deprecated once streams with type hints are deprecated
+        signature = inspect.signature(self.next_call)
+        self.params = list(signature.parameters.values())
+        self.type: UDFType = setup_type(self.params)
+        if self.type == UDFType.WITH_TYPING:
+            self.dependecy_manager.solve_user_fn(fn=self.next_call)
+
+    def get_type(self) -> UDFType:
+        return self.type
+
+    async def __call__(self, cr: types.ConsumerRecord) -> typing.Any:
+        return await self.dependecy_manager.execute(cr)
diff --git a/kstreams/middleware/middleware.py b/kstreams/middleware/middleware.py
index f5b164bd..0173c15d 100644
--- a/kstreams/middleware/middleware.py
+++ b/kstreams/middleware/middleware.py
@@ -4,7 +4,7 @@
 import typing
 
 from kstreams import types
-from kstreams.streams_utils import StreamErrorPolicy
+from kstreams.streams_utils import StreamErrorPolicy, UDFType
 
 if typing.TYPE_CHECKING:
     from kstreams import Stream, StreamEngine  #  pragma: no cover
@@ -14,6 +14,10 @@
 
 
 class MiddlewareProtocol(typing.Protocol):
+    next_call: types.NextMiddlewareCall
+    send: types.Send
+    stream: "Stream"
+
     def __init__(
         self,
         *,
@@ -44,7 +48,11 @@ def __repr__(self) -> str:
         return f"{middleware_name}({extra_options})"
 
 
-class BaseMiddleware:
+class BaseMiddleware(MiddlewareProtocol):
+    next_call: types.NextMiddlewareCall
+    send: types.Send
+    stream: "Stream"
+
     def __init__(
         self,
         *,
@@ -145,3 +153,20 @@ async def cleanup_policy(self, exc: Exception) -> None:
             await self.engine.stop()
             await self.stream.is_processing.acquire()
             signal.raise_signal(signal.SIGTERM)
+
+        # acquire the asyncio.Lock `is_processing` again to resume the processing
+        # and avoid `RuntimeError: Lock is not acquired.`
+        await self.stream.is_processing.acquire()
+
+
+class BaseDependcyMiddleware(MiddlewareProtocol, typing.Protocol):
+    """Base class for Dependency Injection Middleware.
+
+    Both old and new DI middlewares make use of the type.
+
+    The `type` is used to identify the way to call the user defined function.
+
+    On top of that, this middleware helps avoid circular dependencies.
+    """
+
+    def get_type(self) -> UDFType: ...
diff --git a/kstreams/middleware/udf_middleware.py b/kstreams/middleware/udf_middleware.py
index 2bc1f295..f12b1f9d 100644
--- a/kstreams/middleware/udf_middleware.py
+++ b/kstreams/middleware/udf_middleware.py
@@ -21,6 +21,9 @@ def __init__(self, *args, **kwargs) -> None:
         self.params = list(signature.parameters.values())
         self.type: UDFType = setup_type(self.params)
 
+    def get_type(self) -> UDFType:
+        return self.type
+
     def bind_udf_params(self, cr: types.ConsumerRecord) -> typing.List:
         # NOTE: When `no typing` support is deprecated then this can
         # be more eficient as the CR will be always there.
diff --git a/kstreams/streams.py b/kstreams/streams.py
index bf17682e..e6112a21 100644
--- a/kstreams/streams.py
+++ b/kstreams/streams.py
@@ -10,12 +10,12 @@
 
 from kstreams import TopicPartition
 from kstreams.exceptions import BackendNotSet
-from kstreams.middleware.middleware import ExceptionMiddleware
+from kstreams.middleware.middleware import BaseDependcyMiddleware, ExceptionMiddleware
 from kstreams.structs import TopicPartitionOffset
 
 from .backends.kafka import Kafka
 from .clients import Consumer
-from .middleware import Middleware, udf_middleware
+from .middleware import Middleware
 from .rebalance_listener import RebalanceListener
 from .serializers import Deserializer
 from .streams_utils import StreamErrorPolicy, UDFType
@@ -172,11 +172,14 @@ def __init__(
         self.seeked_initial_offsets = False
         self.rebalance_listener = rebalance_listener
         self.middlewares = middlewares or []
-        self.udf_handler: typing.Optional[udf_middleware.UdfHandler] = None
+        self.udf_handler: typing.Optional[BaseDependcyMiddleware] = None
         self.topics = [topics] if isinstance(topics, str) else topics
         self.subscribe_by_pattern = subscribe_by_pattern
         self.error_policy = error_policy
 
+    def __name__(self) -> str:
+        return self.name
+
     def _create_consumer(self) -> Consumer:
         if self.backend is None:
             raise BackendNotSet("A backend has not been set for this stream")
@@ -342,7 +345,7 @@ async def start(self) -> None:
             self.running = True
 
             if self.udf_handler is not None:
-                if self.udf_handler.type == UDFType.NO_TYPING:
+                if self.udf_handler.get_type() == UDFType.NO_TYPING:
                     # deprecated use case
                     msg = (
                         "Streams with `async for in` loop approach are deprecated.\n"
@@ -356,6 +359,10 @@ async def start(self) -> None:
                     await func
                 else:
                     # Typing cases
+
+                    # If it's an async generator, then DON'T await the function
+                    # because we want to start ONLY and let the user retrieve the
+                    # values while iterating the stream
                     if not inspect.isasyncgenfunction(self.udf_handler.next_call):
                         # Is not an async_generator, then create `await` the func
                         await self.func_wrapper_with_typing()
@@ -436,7 +443,7 @@ async def __anext__(self) -> ConsumerRecord:
 
             if (
                 self.udf_handler is not None
-                and self.udf_handler.type == UDFType.NO_TYPING
+                and self.udf_handler.get_type() == UDFType.NO_TYPING
             ):
                 return cr
             return await self.func(cr)
diff --git a/kstreams/types.py b/kstreams/types.py
index 3562f3b6..90107722 100644
--- a/kstreams/types.py
+++ b/kstreams/types.py
@@ -8,8 +8,7 @@
 
 Headers = typing.Dict[str, str]
 EncodedHeaders = typing.Sequence[typing.Tuple[str, bytes]]
-StreamFunc = typing.Callable
-
+StreamFunc = typing.Callable[..., typing.Any]
 EngineHooks = typing.Sequence[typing.Callable[[], typing.Any]]
 
 
diff --git a/kstreams/typing.py b/kstreams/typing.py
new file mode 100644
index 00000000..1707d56b
--- /dev/null
+++ b/kstreams/typing.py
@@ -0,0 +1,8 @@
+"""Remove this file when python3.8 support is dropped."""
+
+import sys
+
+if sys.version_info < (3, 9):
+    from typing_extensions import Annotated as Annotated  # noqa: F401
+else:
+    from typing import Annotated as Annotated  # noqa: F401
diff --git a/poetry.lock b/poetry.lock
index 79d1ec3d..f96edad0 100644
--- a/poetry.lock
+++ b/poetry.lock
@@ -133,13 +133,13 @@ wheel = ">=0.23.0,<1.0"
 
 [[package]]
 name = "async-timeout"
-version = "4.0.3"
+version = "5.0.1"
 description = "Timeout context manager for asyncio programs"
 optional = false
-python-versions = ">=3.7"
+python-versions = ">=3.8"
 files = [
-    {file = "async-timeout-4.0.3.tar.gz", hash = "sha256:4640d96be84d82d02ed59ea2b7105a0f7b33abe8703703cd0ab0bf87c427522f"},
-    {file = "async_timeout-4.0.3-py3-none-any.whl", hash = "sha256:7405140ff1230c310e51dc27b3145b9092d659ce68ff733fb0cefe3ee42be028"},
+    {file = "async_timeout-5.0.1-py3-none-any.whl", hash = "sha256:39e3809566ff85354557ec2398b55e096c8364bacac9405a7a1fa429e77fe76c"},
+    {file = "async_timeout-5.0.1.tar.gz", hash = "sha256:d9321a7a3d5a6a5e187e824d2fa0793ce379a202935782d555d6e9d2735677d3"},
 ]
 
 [[package]]
@@ -446,6 +446,24 @@ files = [
     {file = "decli-0.6.2.tar.gz", hash = "sha256:36f71eb55fd0093895efb4f416ec32b7f6e00147dda448e3365cf73ceab42d6f"},
 ]
 
+[[package]]
+name = "di"
+version = "0.79.2"
+description = "Dependency injection toolkit"
+optional = false
+python-versions = ">=3.8,<4"
+files = [
+    {file = "di-0.79.2-py3-none-any.whl", hash = "sha256:4b2ac7c46d4d9e941ca47d37c2029ba739c1f8a0e19e5288731224870f00d6e6"},
+    {file = "di-0.79.2.tar.gz", hash = "sha256:0c65b9ccb984252dadbdcdb39743eeddef0c1f167f791c59fcd70e97bb0d3af8"},
+]
+
+[package.dependencies]
+graphlib2 = ">=0.4.1,<0.5.0"
+typing-extensions = {version = ">=3", markers = "python_version < \"3.9\""}
+
+[package.extras]
+anyio = ["anyio (>=3.5.0)"]
+
 [[package]]
 name = "exceptiongroup"
 version = "1.2.2"
@@ -460,6 +478,20 @@ files = [
 [package.extras]
 test = ["pytest (>=6)"]
 
+[[package]]
+name = "faker"
+version = "14.2.1"
+description = "Faker is a Python package that generates fake data for you."
+optional = false
+python-versions = ">=3.6"
+files = [
+    {file = "Faker-14.2.1-py3-none-any.whl", hash = "sha256:2e28aaea60456857d4ce95dd12aed767769537ad23d13d51a545cd40a654e9d9"},
+    {file = "Faker-14.2.1.tar.gz", hash = "sha256:daad7badb4fd916bd047b28c8459ef4689e4fe6acf61f6dfebee8cc602e4d009"},
+]
+
+[package.dependencies]
+python-dateutil = ">=2.4"
+
 [[package]]
 name = "fastapi"
 version = "0.115.5"
@@ -508,6 +540,40 @@ python-dateutil = ">=2.8.1"
 [package.extras]
 dev = ["flake8", "markdown", "twine", "wheel"]
 
+[[package]]
+name = "graphlib2"
+version = "0.4.7"
+description = "Rust port of the Python stdlib graphlib modules"
+optional = false
+python-versions = ">=3.7"
+files = [
+    {file = "graphlib2-0.4.7-cp37-abi3-macosx_10_7_x86_64.whl", hash = "sha256:483710733215783cdc76452ccde1247af8f697685c9c1dfd9bb9ff4f52d990ee"},
+    {file = "graphlib2-0.4.7-cp37-abi3-macosx_10_9_x86_64.macosx_11_0_arm64.macosx_10_9_universal2.whl", hash = "sha256:3619c7d3c5aca95e6cbbfc283aa6bf42ffa5b59d7f39c8d0ad615bce65dc406f"},
+    {file = "graphlib2-0.4.7-cp37-abi3-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:5b19f1b91d0f22ca3d1cfb2965478db98cf5916a5c6cea5fdc7caf4bf1bfbc33"},
+    {file = "graphlib2-0.4.7-cp37-abi3-manylinux_2_17_armv7l.manylinux2014_armv7l.whl", hash = "sha256:624020f6808ee21ffbb2e455f8dd4196bbb37032a35aa3327f0f5b65fb6a35d1"},
+    {file = "graphlib2-0.4.7-cp37-abi3-manylinux_2_17_ppc64.manylinux2014_ppc64.whl", hash = "sha256:6efc6a197a619a97f1b105aea14b202101241c1db9014bd100ad19cf29288cbf"},
+    {file = "graphlib2-0.4.7-cp37-abi3-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:d7cc38b68775cb2cdfc487bbaca2f7991da0d76d42a68f412c2ca61461e6e026"},
+    {file = "graphlib2-0.4.7-cp37-abi3-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:b06bed98d42f4e10adfe2a8332efdca06b5bac6e7c86dd1d22a4dea4de9b275a"},
+    {file = "graphlib2-0.4.7-cp37-abi3-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:3c9ec3a5645bdf020d8bd9196b2665e26090d60e523fd498df29628f2c5fbecc"},
+    {file = "graphlib2-0.4.7-cp37-abi3-manylinux_2_5_i686.manylinux1_i686.whl", hash = "sha256:824df87f767471febfd785a05a2cc77c0c973e0112a548df827763ca0aa8c126"},
+    {file = "graphlib2-0.4.7-cp37-abi3-musllinux_1_2_aarch64.whl", hash = "sha256:2de5e32ca5c0b06d442d2be4b378cc0bc335c5fcbc14a7d531a621eb8294d019"},
+    {file = "graphlib2-0.4.7-cp37-abi3-musllinux_1_2_armv7l.whl", hash = "sha256:13a23fcf07c7bef8a5ad0e04ab826d3a2a2bcb493197005300c68b4ea7b8f581"},
+    {file = "graphlib2-0.4.7-cp37-abi3-musllinux_1_2_i686.whl", hash = "sha256:15a8a6daa28c1fb5c518d387879f3bbe313264fbbc2fab5635b718bc71a24913"},
+    {file = "graphlib2-0.4.7-cp37-abi3-musllinux_1_2_x86_64.whl", hash = "sha256:0cb6c4449834077972c3cea4602f86513b4b75fcf2d40b12e4fe4bf1aa5c8da2"},
+    {file = "graphlib2-0.4.7-cp37-abi3-win32.whl", hash = "sha256:31b40cea537845d80b69403ae306d7c6a68716b76f5171f68daed1804aadefec"},
+    {file = "graphlib2-0.4.7-cp37-abi3-win_amd64.whl", hash = "sha256:d40935a9da81a046ebcaa0216ad593ef504ae8a5425a59bdbd254c0462adedc8"},
+    {file = "graphlib2-0.4.7-pp37-pypy37_pp73-macosx_10_7_x86_64.whl", hash = "sha256:9cef08a50632e75a9e11355e68fa1f8c9371d0734642855f8b5c4ead1b058e6f"},
+    {file = "graphlib2-0.4.7-pp37-pypy37_pp73-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:aeecb604d70317c20ca6bc3556f7f5c40146ad1f0ded837e978b2fe6edf3e567"},
+    {file = "graphlib2-0.4.7-pp37-pypy37_pp73-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:cb4ae9df7ed895c6557619049c9f73e1c2e6d1fbed568010fd5d4af94e2f0692"},
+    {file = "graphlib2-0.4.7-pp38-pypy38_pp73-macosx_10_7_x86_64.whl", hash = "sha256:3ee3a99fc39df948fef340b01254709cc603263f8b176f72ed26f1eea44070a4"},
+    {file = "graphlib2-0.4.7-pp38-pypy38_pp73-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:5873480df8991273bd1585122df232acd0f946c401c254bd9f0d661c72589dcf"},
+    {file = "graphlib2-0.4.7-pp38-pypy38_pp73-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:297c817229501255cd3a744c62c8f91e5139ee79bc550488f5bc765ffa33f7c5"},
+    {file = "graphlib2-0.4.7-pp39-pypy39_pp73-macosx_10_7_x86_64.whl", hash = "sha256:853ef22df8e9f695706e0b8556cda9342d4d617f7d7bd02803e824bcc0c30b20"},
+    {file = "graphlib2-0.4.7-pp39-pypy39_pp73-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:ee62ff1042fde980adf668e30393eca79aee8f1fa1274ab3b98d69091c70c5e8"},
+    {file = "graphlib2-0.4.7-pp39-pypy39_pp73-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:b16e21e70938132d4160c2591fed59f79b5f8b702e4860c8933111b5fedb55c2"},
+    {file = "graphlib2-0.4.7.tar.gz", hash = "sha256:a951c18cb4c2c2834eec898b4c75d3f930d6f08beb37496f0e0ce56eb3f571f5"},
+]
+
 [[package]]
 name = "griffe"
 version = "1.4.0"
@@ -584,22 +650,22 @@ files = [
 
 [[package]]
 name = "jedi"
-version = "0.19.1"
+version = "0.19.2"
 description = "An autocompletion tool for Python that can be used for text editors."
 optional = false
 python-versions = ">=3.6"
 files = [
-    {file = "jedi-0.19.1-py2.py3-none-any.whl", hash = "sha256:e983c654fe5c02867aef4cdfce5a2fbb4a50adc0af145f70504238f18ef5e7e0"},
-    {file = "jedi-0.19.1.tar.gz", hash = "sha256:cf0496f3651bc65d7174ac1b7d043eff454892c708a87d1b683e57b569927ffd"},
+    {file = "jedi-0.19.2-py2.py3-none-any.whl", hash = "sha256:a8ef22bde8490f57fe5c7681a3c83cb58874daf72b4784de3cce5b6ef6edb5b9"},
+    {file = "jedi-0.19.2.tar.gz", hash = "sha256:4770dc3de41bde3966b02eb84fbcf557fb33cce26ad23da12c742fb50ecb11f0"},
 ]
 
 [package.dependencies]
-parso = ">=0.8.3,<0.9.0"
+parso = ">=0.8.4,<0.9.0"
 
 [package.extras]
 docs = ["Jinja2 (==2.11.3)", "MarkupSafe (==1.1.1)", "Pygments (==2.8.1)", "alabaster (==0.7.12)", "babel (==2.9.1)", "chardet (==4.0.0)", "commonmark (==0.8.1)", "docutils (==0.17.1)", "future (==0.18.2)", "idna (==2.10)", "imagesize (==1.2.0)", "mock (==1.0.1)", "packaging (==20.9)", "pyparsing (==2.4.7)", "pytz (==2021.1)", "readthedocs-sphinx-ext (==2.1.4)", "recommonmark (==0.5.0)", "requests (==2.25.1)", "six (==1.15.0)", "snowballstemmer (==2.1.0)", "sphinx (==1.8.5)", "sphinx-rtd-theme (==0.4.3)", "sphinxcontrib-serializinghtml (==1.1.4)", "sphinxcontrib-websupport (==1.2.4)", "urllib3 (==1.26.4)"]
 qa = ["flake8 (==5.0.4)", "mypy (==0.971)", "types-setuptools (==67.2.0.1)"]
-testing = ["Django", "attrs", "colorama", "docopt", "pytest (<7.0.0)"]
+testing = ["Django", "attrs", "colorama", "docopt", "pytest (<9.0.0)"]
 
 [[package]]
 name = "jinja2"
@@ -931,13 +997,13 @@ files = [
 
 [[package]]
 name = "packaging"
-version = "24.1"
+version = "24.2"
 description = "Core utilities for Python packages"
 optional = false
 python-versions = ">=3.8"
 files = [
-    {file = "packaging-24.1-py3-none-any.whl", hash = "sha256:5b8f2217dbdbd2f7f384c41c628544e6d52f2d0f53c6d0c3ea61aa5d1d7ff124"},
-    {file = "packaging-24.1.tar.gz", hash = "sha256:026ed72c8ed3fcce5bf8950572258698927fd1dbda10a5e981cdf0ac37f4f002"},
+    {file = "packaging-24.2-py3-none-any.whl", hash = "sha256:09abb1bccd265c01f4a3aa3f7a7db064b36514d2cba19a2f694fe6150451a759"},
+    {file = "packaging-24.2.tar.gz", hash = "sha256:c228a6dc5e932d346bc5739379109d49e8853dd8223571c7c5b55260edc0b97f"},
 ]
 
 [[package]]
@@ -1180,13 +1246,13 @@ windows-terminal = ["colorama (>=0.4.6)"]
 
 [[package]]
 name = "pymdown-extensions"
-version = "10.11.2"
+version = "10.12"
 description = "Extension pack for Python Markdown."
 optional = false
 python-versions = ">=3.8"
 files = [
-    {file = "pymdown_extensions-10.11.2-py3-none-any.whl", hash = "sha256:41cdde0a77290e480cf53892f5c5e50921a7ee3e5cd60ba91bf19837b33badcf"},
-    {file = "pymdown_extensions-10.11.2.tar.gz", hash = "sha256:bc8847ecc9e784a098efd35e20cba772bc5a1b529dfcef9dc1972db9021a1049"},
+    {file = "pymdown_extensions-10.12-py3-none-any.whl", hash = "sha256:49f81412242d3527b8b4967b990df395c89563043bc51a3d2d7d500e52123b77"},
+    {file = "pymdown_extensions-10.12.tar.gz", hash = "sha256:b0ee1e0b2bef1071a47891ab17003bfe5bf824a398e13f49f8ed653b699369a7"},
 ]
 
 [package.dependencies]
@@ -1385,105 +1451,105 @@ prompt_toolkit = ">=2.0,<=3.0.36"
 
 [[package]]
 name = "regex"
-version = "2024.9.11"
+version = "2024.11.6"
 description = "Alternative regular expression module, to replace re."
 optional = false
 python-versions = ">=3.8"
 files = [
-    {file = "regex-2024.9.11-cp310-cp310-macosx_10_9_universal2.whl", hash = "sha256:1494fa8725c285a81d01dc8c06b55287a1ee5e0e382d8413adc0a9197aac6408"},
-    {file = "regex-2024.9.11-cp310-cp310-macosx_10_9_x86_64.whl", hash = "sha256:0e12c481ad92d129c78f13a2a3662317e46ee7ef96c94fd332e1c29131875b7d"},
-    {file = "regex-2024.9.11-cp310-cp310-macosx_11_0_arm64.whl", hash = "sha256:16e13a7929791ac1216afde26f712802e3df7bf0360b32e4914dca3ab8baeea5"},
-    {file = "regex-2024.9.11-cp310-cp310-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:46989629904bad940bbec2106528140a218b4a36bb3042d8406980be1941429c"},
-    {file = "regex-2024.9.11-cp310-cp310-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:a906ed5e47a0ce5f04b2c981af1c9acf9e8696066900bf03b9d7879a6f679fc8"},
-    {file = "regex-2024.9.11-cp310-cp310-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:e9a091b0550b3b0207784a7d6d0f1a00d1d1c8a11699c1a4d93db3fbefc3ad35"},
-    {file = "regex-2024.9.11-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:5ddcd9a179c0a6fa8add279a4444015acddcd7f232a49071ae57fa6e278f1f71"},
-    {file = "regex-2024.9.11-cp310-cp310-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:6b41e1adc61fa347662b09398e31ad446afadff932a24807d3ceb955ed865cc8"},
-    {file = "regex-2024.9.11-cp310-cp310-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_12_x86_64.manylinux2010_x86_64.whl", hash = "sha256:ced479f601cd2f8ca1fd7b23925a7e0ad512a56d6e9476f79b8f381d9d37090a"},
-    {file = "regex-2024.9.11-cp310-cp310-musllinux_1_2_aarch64.whl", hash = "sha256:635a1d96665f84b292e401c3d62775851aedc31d4f8784117b3c68c4fcd4118d"},
-    {file = "regex-2024.9.11-cp310-cp310-musllinux_1_2_i686.whl", hash = "sha256:c0256beda696edcf7d97ef16b2a33a8e5a875affd6fa6567b54f7c577b30a137"},
-    {file = "regex-2024.9.11-cp310-cp310-musllinux_1_2_ppc64le.whl", hash = "sha256:3ce4f1185db3fbde8ed8aa223fc9620f276c58de8b0d4f8cc86fd1360829edb6"},
-    {file = "regex-2024.9.11-cp310-cp310-musllinux_1_2_s390x.whl", hash = "sha256:09d77559e80dcc9d24570da3745ab859a9cf91953062e4ab126ba9d5993688ca"},
-    {file = "regex-2024.9.11-cp310-cp310-musllinux_1_2_x86_64.whl", hash = "sha256:7a22ccefd4db3f12b526eccb129390942fe874a3a9fdbdd24cf55773a1faab1a"},
-    {file = "regex-2024.9.11-cp310-cp310-win32.whl", hash = "sha256:f745ec09bc1b0bd15cfc73df6fa4f726dcc26bb16c23a03f9e3367d357eeedd0"},
-    {file = "regex-2024.9.11-cp310-cp310-win_amd64.whl", hash = "sha256:01c2acb51f8a7d6494c8c5eafe3d8e06d76563d8a8a4643b37e9b2dd8a2ff623"},
-    {file = "regex-2024.9.11-cp311-cp311-macosx_10_9_universal2.whl", hash = "sha256:2cce2449e5927a0bf084d346da6cd5eb016b2beca10d0013ab50e3c226ffc0df"},
-    {file = "regex-2024.9.11-cp311-cp311-macosx_10_9_x86_64.whl", hash = "sha256:3b37fa423beefa44919e009745ccbf353d8c981516e807995b2bd11c2c77d268"},
-    {file = "regex-2024.9.11-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:64ce2799bd75039b480cc0360907c4fb2f50022f030bf9e7a8705b636e408fad"},
-    {file = "regex-2024.9.11-cp311-cp311-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:a4cc92bb6db56ab0c1cbd17294e14f5e9224f0cc6521167ef388332604e92679"},
-    {file = "regex-2024.9.11-cp311-cp311-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:d05ac6fa06959c4172eccd99a222e1fbf17b5670c4d596cb1e5cde99600674c4"},
-    {file = "regex-2024.9.11-cp311-cp311-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:040562757795eeea356394a7fb13076ad4f99d3c62ab0f8bdfb21f99a1f85664"},
-    {file = "regex-2024.9.11-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:6113c008a7780792efc80f9dfe10ba0cd043cbf8dc9a76ef757850f51b4edc50"},
-    {file = "regex-2024.9.11-cp311-cp311-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:8e5fb5f77c8745a60105403a774fe2c1759b71d3e7b4ca237a5e67ad066c7199"},
-    {file = "regex-2024.9.11-cp311-cp311-musllinux_1_2_aarch64.whl", hash = "sha256:54d9ff35d4515debf14bc27f1e3b38bfc453eff3220f5bce159642fa762fe5d4"},
-    {file = "regex-2024.9.11-cp311-cp311-musllinux_1_2_i686.whl", hash = "sha256:df5cbb1fbc74a8305b6065d4ade43b993be03dbe0f8b30032cced0d7740994bd"},
-    {file = "regex-2024.9.11-cp311-cp311-musllinux_1_2_ppc64le.whl", hash = "sha256:7fb89ee5d106e4a7a51bce305ac4efb981536301895f7bdcf93ec92ae0d91c7f"},
-    {file = "regex-2024.9.11-cp311-cp311-musllinux_1_2_s390x.whl", hash = "sha256:a738b937d512b30bf75995c0159c0ddf9eec0775c9d72ac0202076c72f24aa96"},
-    {file = "regex-2024.9.11-cp311-cp311-musllinux_1_2_x86_64.whl", hash = "sha256:e28f9faeb14b6f23ac55bfbbfd3643f5c7c18ede093977f1df249f73fd22c7b1"},
-    {file = "regex-2024.9.11-cp311-cp311-win32.whl", hash = "sha256:18e707ce6c92d7282dfce370cd205098384b8ee21544e7cb29b8aab955b66fa9"},
-    {file = "regex-2024.9.11-cp311-cp311-win_amd64.whl", hash = "sha256:313ea15e5ff2a8cbbad96ccef6be638393041b0a7863183c2d31e0c6116688cf"},
-    {file = "regex-2024.9.11-cp312-cp312-macosx_10_9_universal2.whl", hash = "sha256:b0d0a6c64fcc4ef9c69bd5b3b3626cc3776520a1637d8abaa62b9edc147a58f7"},
-    {file = "regex-2024.9.11-cp312-cp312-macosx_10_9_x86_64.whl", hash = "sha256:49b0e06786ea663f933f3710a51e9385ce0cba0ea56b67107fd841a55d56a231"},
-    {file = "regex-2024.9.11-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:5b513b6997a0b2f10e4fd3a1313568e373926e8c252bd76c960f96fd039cd28d"},
-    {file = "regex-2024.9.11-cp312-cp312-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:ee439691d8c23e76f9802c42a95cfeebf9d47cf4ffd06f18489122dbb0a7ad64"},
-    {file = "regex-2024.9.11-cp312-cp312-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:a8f877c89719d759e52783f7fe6e1c67121076b87b40542966c02de5503ace42"},
-    {file = "regex-2024.9.11-cp312-cp312-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:23b30c62d0f16827f2ae9f2bb87619bc4fba2044911e2e6c2eb1af0161cdb766"},
-    {file = "regex-2024.9.11-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:85ab7824093d8f10d44330fe1e6493f756f252d145323dd17ab6b48733ff6c0a"},
-    {file = "regex-2024.9.11-cp312-cp312-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:8dee5b4810a89447151999428fe096977346cf2f29f4d5e29609d2e19e0199c9"},
-    {file = "regex-2024.9.11-cp312-cp312-musllinux_1_2_aarch64.whl", hash = "sha256:98eeee2f2e63edae2181c886d7911ce502e1292794f4c5ee71e60e23e8d26b5d"},
-    {file = "regex-2024.9.11-cp312-cp312-musllinux_1_2_i686.whl", hash = "sha256:57fdd2e0b2694ce6fc2e5ccf189789c3e2962916fb38779d3e3521ff8fe7a822"},
-    {file = "regex-2024.9.11-cp312-cp312-musllinux_1_2_ppc64le.whl", hash = "sha256:d552c78411f60b1fdaafd117a1fca2f02e562e309223b9d44b7de8be451ec5e0"},
-    {file = "regex-2024.9.11-cp312-cp312-musllinux_1_2_s390x.whl", hash = "sha256:a0b2b80321c2ed3fcf0385ec9e51a12253c50f146fddb2abbb10f033fe3d049a"},
-    {file = "regex-2024.9.11-cp312-cp312-musllinux_1_2_x86_64.whl", hash = "sha256:18406efb2f5a0e57e3a5881cd9354c1512d3bb4f5c45d96d110a66114d84d23a"},
-    {file = "regex-2024.9.11-cp312-cp312-win32.whl", hash = "sha256:e464b467f1588e2c42d26814231edecbcfe77f5ac414d92cbf4e7b55b2c2a776"},
-    {file = "regex-2024.9.11-cp312-cp312-win_amd64.whl", hash = "sha256:9e8719792ca63c6b8340380352c24dcb8cd7ec49dae36e963742a275dfae6009"},
-    {file = "regex-2024.9.11-cp313-cp313-macosx_10_13_universal2.whl", hash = "sha256:c157bb447303070f256e084668b702073db99bbb61d44f85d811025fcf38f784"},
-    {file = "regex-2024.9.11-cp313-cp313-macosx_10_13_x86_64.whl", hash = "sha256:4db21ece84dfeefc5d8a3863f101995de646c6cb0536952c321a2650aa202c36"},
-    {file = "regex-2024.9.11-cp313-cp313-macosx_11_0_arm64.whl", hash = "sha256:220e92a30b426daf23bb67a7962900ed4613589bab80382be09b48896d211e92"},
-    {file = "regex-2024.9.11-cp313-cp313-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:eb1ae19e64c14c7ec1995f40bd932448713d3c73509e82d8cd7744dc00e29e86"},
-    {file = "regex-2024.9.11-cp313-cp313-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:f47cd43a5bfa48f86925fe26fbdd0a488ff15b62468abb5d2a1e092a4fb10e85"},
-    {file = "regex-2024.9.11-cp313-cp313-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:9d4a76b96f398697fe01117093613166e6aa8195d63f1b4ec3f21ab637632963"},
-    {file = "regex-2024.9.11-cp313-cp313-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:0ea51dcc0835eea2ea31d66456210a4e01a076d820e9039b04ae8d17ac11dee6"},
-    {file = "regex-2024.9.11-cp313-cp313-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:b7aaa315101c6567a9a45d2839322c51c8d6e81f67683d529512f5bcfb99c802"},
-    {file = "regex-2024.9.11-cp313-cp313-musllinux_1_2_aarch64.whl", hash = "sha256:c57d08ad67aba97af57a7263c2d9006d5c404d721c5f7542f077f109ec2a4a29"},
-    {file = "regex-2024.9.11-cp313-cp313-musllinux_1_2_i686.whl", hash = "sha256:f8404bf61298bb6f8224bb9176c1424548ee1181130818fcd2cbffddc768bed8"},
-    {file = "regex-2024.9.11-cp313-cp313-musllinux_1_2_ppc64le.whl", hash = "sha256:dd4490a33eb909ef5078ab20f5f000087afa2a4daa27b4c072ccb3cb3050ad84"},
-    {file = "regex-2024.9.11-cp313-cp313-musllinux_1_2_s390x.whl", hash = "sha256:eee9130eaad130649fd73e5cd92f60e55708952260ede70da64de420cdcad554"},
-    {file = "regex-2024.9.11-cp313-cp313-musllinux_1_2_x86_64.whl", hash = "sha256:6a2644a93da36c784e546de579ec1806bfd2763ef47babc1b03d765fe560c9f8"},
-    {file = "regex-2024.9.11-cp313-cp313-win32.whl", hash = "sha256:e997fd30430c57138adc06bba4c7c2968fb13d101e57dd5bb9355bf8ce3fa7e8"},
-    {file = "regex-2024.9.11-cp313-cp313-win_amd64.whl", hash = "sha256:042c55879cfeb21a8adacc84ea347721d3d83a159da6acdf1116859e2427c43f"},
-    {file = "regex-2024.9.11-cp38-cp38-macosx_10_9_universal2.whl", hash = "sha256:35f4a6f96aa6cb3f2f7247027b07b15a374f0d5b912c0001418d1d55024d5cb4"},
-    {file = "regex-2024.9.11-cp38-cp38-macosx_10_9_x86_64.whl", hash = "sha256:55b96e7ce3a69a8449a66984c268062fbaa0d8ae437b285428e12797baefce7e"},
-    {file = "regex-2024.9.11-cp38-cp38-macosx_11_0_arm64.whl", hash = "sha256:cb130fccd1a37ed894824b8c046321540263013da72745d755f2d35114b81a60"},
-    {file = "regex-2024.9.11-cp38-cp38-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:323c1f04be6b2968944d730e5c2091c8c89767903ecaa135203eec4565ed2b2b"},
-    {file = "regex-2024.9.11-cp38-cp38-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:be1c8ed48c4c4065ecb19d882a0ce1afe0745dfad8ce48c49586b90a55f02366"},
-    {file = "regex-2024.9.11-cp38-cp38-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:b5b029322e6e7b94fff16cd120ab35a253236a5f99a79fb04fda7ae71ca20ae8"},
-    {file = "regex-2024.9.11-cp38-cp38-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:f6fff13ef6b5f29221d6904aa816c34701462956aa72a77f1f151a8ec4f56aeb"},
-    {file = "regex-2024.9.11-cp38-cp38-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:587d4af3979376652010e400accc30404e6c16b7df574048ab1f581af82065e4"},
-    {file = "regex-2024.9.11-cp38-cp38-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_12_x86_64.manylinux2010_x86_64.whl", hash = "sha256:079400a8269544b955ffa9e31f186f01d96829110a3bf79dc338e9910f794fca"},
-    {file = "regex-2024.9.11-cp38-cp38-musllinux_1_2_aarch64.whl", hash = "sha256:f9268774428ec173654985ce55fc6caf4c6d11ade0f6f914d48ef4719eb05ebb"},
-    {file = "regex-2024.9.11-cp38-cp38-musllinux_1_2_i686.whl", hash = "sha256:23f9985c8784e544d53fc2930fc1ac1a7319f5d5332d228437acc9f418f2f168"},
-    {file = "regex-2024.9.11-cp38-cp38-musllinux_1_2_ppc64le.whl", hash = "sha256:ae2941333154baff9838e88aa71c1d84f4438189ecc6021a12c7573728b5838e"},
-    {file = "regex-2024.9.11-cp38-cp38-musllinux_1_2_s390x.whl", hash = "sha256:e93f1c331ca8e86fe877a48ad64e77882c0c4da0097f2212873a69bbfea95d0c"},
-    {file = "regex-2024.9.11-cp38-cp38-musllinux_1_2_x86_64.whl", hash = "sha256:846bc79ee753acf93aef4184c040d709940c9d001029ceb7b7a52747b80ed2dd"},
-    {file = "regex-2024.9.11-cp38-cp38-win32.whl", hash = "sha256:c94bb0a9f1db10a1d16c00880bdebd5f9faf267273b8f5bd1878126e0fbde771"},
-    {file = "regex-2024.9.11-cp38-cp38-win_amd64.whl", hash = "sha256:2b08fce89fbd45664d3df6ad93e554b6c16933ffa9d55cb7e01182baaf971508"},
-    {file = "regex-2024.9.11-cp39-cp39-macosx_10_9_universal2.whl", hash = "sha256:07f45f287469039ffc2c53caf6803cd506eb5f5f637f1d4acb37a738f71dd066"},
-    {file = "regex-2024.9.11-cp39-cp39-macosx_10_9_x86_64.whl", hash = "sha256:4838e24ee015101d9f901988001038f7f0d90dc0c3b115541a1365fb439add62"},
-    {file = "regex-2024.9.11-cp39-cp39-macosx_11_0_arm64.whl", hash = "sha256:6edd623bae6a737f10ce853ea076f56f507fd7726bee96a41ee3d68d347e4d16"},
-    {file = "regex-2024.9.11-cp39-cp39-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:c69ada171c2d0e97a4b5aa78fbb835e0ffbb6b13fc5da968c09811346564f0d3"},
-    {file = "regex-2024.9.11-cp39-cp39-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:02087ea0a03b4af1ed6ebab2c54d7118127fee8d71b26398e8e4b05b78963199"},
-    {file = "regex-2024.9.11-cp39-cp39-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:69dee6a020693d12a3cf892aba4808fe168d2a4cef368eb9bf74f5398bfd4ee8"},
-    {file = "regex-2024.9.11-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:297f54910247508e6e5cae669f2bc308985c60540a4edd1c77203ef19bfa63ca"},
-    {file = "regex-2024.9.11-cp39-cp39-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:ecea58b43a67b1b79805f1a0255730edaf5191ecef84dbc4cc85eb30bc8b63b9"},
-    {file = "regex-2024.9.11-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_12_x86_64.manylinux2010_x86_64.whl", hash = "sha256:eab4bb380f15e189d1313195b062a6aa908f5bd687a0ceccd47c8211e9cf0d4a"},
-    {file = "regex-2024.9.11-cp39-cp39-musllinux_1_2_aarch64.whl", hash = "sha256:0cbff728659ce4bbf4c30b2a1be040faafaa9eca6ecde40aaff86f7889f4ab39"},
-    {file = "regex-2024.9.11-cp39-cp39-musllinux_1_2_i686.whl", hash = "sha256:54c4a097b8bc5bb0dfc83ae498061d53ad7b5762e00f4adaa23bee22b012e6ba"},
-    {file = "regex-2024.9.11-cp39-cp39-musllinux_1_2_ppc64le.whl", hash = "sha256:73d6d2f64f4d894c96626a75578b0bf7d9e56dcda8c3d037a2118fdfe9b1c664"},
-    {file = "regex-2024.9.11-cp39-cp39-musllinux_1_2_s390x.whl", hash = "sha256:e53b5fbab5d675aec9f0c501274c467c0f9a5d23696cfc94247e1fb56501ed89"},
-    {file = "regex-2024.9.11-cp39-cp39-musllinux_1_2_x86_64.whl", hash = "sha256:0ffbcf9221e04502fc35e54d1ce9567541979c3fdfb93d2c554f0ca583a19b35"},
-    {file = "regex-2024.9.11-cp39-cp39-win32.whl", hash = "sha256:e4c22e1ac1f1ec1e09f72e6c44d8f2244173db7eb9629cc3a346a8d7ccc31142"},
-    {file = "regex-2024.9.11-cp39-cp39-win_amd64.whl", hash = "sha256:faa3c142464efec496967359ca99696c896c591c56c53506bac1ad465f66e919"},
-    {file = "regex-2024.9.11.tar.gz", hash = "sha256:6c188c307e8433bcb63dc1915022deb553b4203a70722fc542c363bf120a01fd"},
+    {file = "regex-2024.11.6-cp310-cp310-macosx_10_9_universal2.whl", hash = "sha256:ff590880083d60acc0433f9c3f713c51f7ac6ebb9adf889c79a261ecf541aa91"},
+    {file = "regex-2024.11.6-cp310-cp310-macosx_10_9_x86_64.whl", hash = "sha256:658f90550f38270639e83ce492f27d2c8d2cd63805c65a13a14d36ca126753f0"},
+    {file = "regex-2024.11.6-cp310-cp310-macosx_11_0_arm64.whl", hash = "sha256:164d8b7b3b4bcb2068b97428060b2a53be050085ef94eca7f240e7947f1b080e"},
+    {file = "regex-2024.11.6-cp310-cp310-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:d3660c82f209655a06b587d55e723f0b813d3a7db2e32e5e7dc64ac2a9e86fde"},
+    {file = "regex-2024.11.6-cp310-cp310-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:d22326fcdef5e08c154280b71163ced384b428343ae16a5ab2b3354aed12436e"},
+    {file = "regex-2024.11.6-cp310-cp310-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:f1ac758ef6aebfc8943560194e9fd0fa18bcb34d89fd8bd2af18183afd8da3a2"},
+    {file = "regex-2024.11.6-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:997d6a487ff00807ba810e0f8332c18b4eb8d29463cfb7c820dc4b6e7562d0cf"},
+    {file = "regex-2024.11.6-cp310-cp310-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:02a02d2bb04fec86ad61f3ea7f49c015a0681bf76abb9857f945d26159d2968c"},
+    {file = "regex-2024.11.6-cp310-cp310-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_12_x86_64.manylinux2010_x86_64.whl", hash = "sha256:f02f93b92358ee3f78660e43b4b0091229260c5d5c408d17d60bf26b6c900e86"},
+    {file = "regex-2024.11.6-cp310-cp310-musllinux_1_2_aarch64.whl", hash = "sha256:06eb1be98df10e81ebaded73fcd51989dcf534e3c753466e4b60c4697a003b67"},
+    {file = "regex-2024.11.6-cp310-cp310-musllinux_1_2_i686.whl", hash = "sha256:040df6fe1a5504eb0f04f048e6d09cd7c7110fef851d7c567a6b6e09942feb7d"},
+    {file = "regex-2024.11.6-cp310-cp310-musllinux_1_2_ppc64le.whl", hash = "sha256:fdabbfc59f2c6edba2a6622c647b716e34e8e3867e0ab975412c5c2f79b82da2"},
+    {file = "regex-2024.11.6-cp310-cp310-musllinux_1_2_s390x.whl", hash = "sha256:8447d2d39b5abe381419319f942de20b7ecd60ce86f16a23b0698f22e1b70008"},
+    {file = "regex-2024.11.6-cp310-cp310-musllinux_1_2_x86_64.whl", hash = "sha256:da8f5fc57d1933de22a9e23eec290a0d8a5927a5370d24bda9a6abe50683fe62"},
+    {file = "regex-2024.11.6-cp310-cp310-win32.whl", hash = "sha256:b489578720afb782f6ccf2840920f3a32e31ba28a4b162e13900c3e6bd3f930e"},
+    {file = "regex-2024.11.6-cp310-cp310-win_amd64.whl", hash = "sha256:5071b2093e793357c9d8b2929dfc13ac5f0a6c650559503bb81189d0a3814519"},
+    {file = "regex-2024.11.6-cp311-cp311-macosx_10_9_universal2.whl", hash = "sha256:5478c6962ad548b54a591778e93cd7c456a7a29f8eca9c49e4f9a806dcc5d638"},
+    {file = "regex-2024.11.6-cp311-cp311-macosx_10_9_x86_64.whl", hash = "sha256:2c89a8cc122b25ce6945f0423dc1352cb9593c68abd19223eebbd4e56612c5b7"},
+    {file = "regex-2024.11.6-cp311-cp311-macosx_11_0_arm64.whl", hash = "sha256:94d87b689cdd831934fa3ce16cc15cd65748e6d689f5d2b8f4f4df2065c9fa20"},
+    {file = "regex-2024.11.6-cp311-cp311-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:1062b39a0a2b75a9c694f7a08e7183a80c63c0d62b301418ffd9c35f55aaa114"},
+    {file = "regex-2024.11.6-cp311-cp311-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:167ed4852351d8a750da48712c3930b031f6efdaa0f22fa1933716bfcd6bf4a3"},
+    {file = "regex-2024.11.6-cp311-cp311-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:2d548dafee61f06ebdb584080621f3e0c23fff312f0de1afc776e2a2ba99a74f"},
+    {file = "regex-2024.11.6-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:f2a19f302cd1ce5dd01a9099aaa19cae6173306d1302a43b627f62e21cf18ac0"},
+    {file = "regex-2024.11.6-cp311-cp311-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:bec9931dfb61ddd8ef2ebc05646293812cb6b16b60cf7c9511a832b6f1854b55"},
+    {file = "regex-2024.11.6-cp311-cp311-musllinux_1_2_aarch64.whl", hash = "sha256:9714398225f299aa85267fd222f7142fcb5c769e73d7733344efc46f2ef5cf89"},
+    {file = "regex-2024.11.6-cp311-cp311-musllinux_1_2_i686.whl", hash = "sha256:202eb32e89f60fc147a41e55cb086db2a3f8cb82f9a9a88440dcfc5d37faae8d"},
+    {file = "regex-2024.11.6-cp311-cp311-musllinux_1_2_ppc64le.whl", hash = "sha256:4181b814e56078e9b00427ca358ec44333765f5ca1b45597ec7446d3a1ef6e34"},
+    {file = "regex-2024.11.6-cp311-cp311-musllinux_1_2_s390x.whl", hash = "sha256:068376da5a7e4da51968ce4c122a7cd31afaaec4fccc7856c92f63876e57b51d"},
+    {file = "regex-2024.11.6-cp311-cp311-musllinux_1_2_x86_64.whl", hash = "sha256:ac10f2c4184420d881a3475fb2c6f4d95d53a8d50209a2500723d831036f7c45"},
+    {file = "regex-2024.11.6-cp311-cp311-win32.whl", hash = "sha256:c36f9b6f5f8649bb251a5f3f66564438977b7ef8386a52460ae77e6070d309d9"},
+    {file = "regex-2024.11.6-cp311-cp311-win_amd64.whl", hash = "sha256:02e28184be537f0e75c1f9b2f8847dc51e08e6e171c6bde130b2687e0c33cf60"},
+    {file = "regex-2024.11.6-cp312-cp312-macosx_10_13_universal2.whl", hash = "sha256:52fb28f528778f184f870b7cf8f225f5eef0a8f6e3778529bdd40c7b3920796a"},
+    {file = "regex-2024.11.6-cp312-cp312-macosx_10_13_x86_64.whl", hash = "sha256:fdd6028445d2460f33136c55eeb1f601ab06d74cb3347132e1c24250187500d9"},
+    {file = "regex-2024.11.6-cp312-cp312-macosx_11_0_arm64.whl", hash = "sha256:805e6b60c54bf766b251e94526ebad60b7de0c70f70a4e6210ee2891acb70bf2"},
+    {file = "regex-2024.11.6-cp312-cp312-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:b85c2530be953a890eaffde05485238f07029600e8f098cdf1848d414a8b45e4"},
+    {file = "regex-2024.11.6-cp312-cp312-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:bb26437975da7dc36b7efad18aa9dd4ea569d2357ae6b783bf1118dabd9ea577"},
+    {file = "regex-2024.11.6-cp312-cp312-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:abfa5080c374a76a251ba60683242bc17eeb2c9818d0d30117b4486be10c59d3"},
+    {file = "regex-2024.11.6-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:70b7fa6606c2881c1db9479b0eaa11ed5dfa11c8d60a474ff0e095099f39d98e"},
+    {file = "regex-2024.11.6-cp312-cp312-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:0c32f75920cf99fe6b6c539c399a4a128452eaf1af27f39bce8909c9a3fd8cbe"},
+    {file = "regex-2024.11.6-cp312-cp312-musllinux_1_2_aarch64.whl", hash = "sha256:982e6d21414e78e1f51cf595d7f321dcd14de1f2881c5dc6a6e23bbbbd68435e"},
+    {file = "regex-2024.11.6-cp312-cp312-musllinux_1_2_i686.whl", hash = "sha256:a7c2155f790e2fb448faed6dd241386719802296ec588a8b9051c1f5c481bc29"},
+    {file = "regex-2024.11.6-cp312-cp312-musllinux_1_2_ppc64le.whl", hash = "sha256:149f5008d286636e48cd0b1dd65018548944e495b0265b45e1bffecce1ef7f39"},
+    {file = "regex-2024.11.6-cp312-cp312-musllinux_1_2_s390x.whl", hash = "sha256:e5364a4502efca094731680e80009632ad6624084aff9a23ce8c8c6820de3e51"},
+    {file = "regex-2024.11.6-cp312-cp312-musllinux_1_2_x86_64.whl", hash = "sha256:0a86e7eeca091c09e021db8eb72d54751e527fa47b8d5787caf96d9831bd02ad"},
+    {file = "regex-2024.11.6-cp312-cp312-win32.whl", hash = "sha256:32f9a4c643baad4efa81d549c2aadefaeba12249b2adc5af541759237eee1c54"},
+    {file = "regex-2024.11.6-cp312-cp312-win_amd64.whl", hash = "sha256:a93c194e2df18f7d264092dc8539b8ffb86b45b899ab976aa15d48214138e81b"},
+    {file = "regex-2024.11.6-cp313-cp313-macosx_10_13_universal2.whl", hash = "sha256:a6ba92c0bcdf96cbf43a12c717eae4bc98325ca3730f6b130ffa2e3c3c723d84"},
+    {file = "regex-2024.11.6-cp313-cp313-macosx_10_13_x86_64.whl", hash = "sha256:525eab0b789891ac3be914d36893bdf972d483fe66551f79d3e27146191a37d4"},
+    {file = "regex-2024.11.6-cp313-cp313-macosx_11_0_arm64.whl", hash = "sha256:086a27a0b4ca227941700e0b31425e7a28ef1ae8e5e05a33826e17e47fbfdba0"},
+    {file = "regex-2024.11.6-cp313-cp313-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:bde01f35767c4a7899b7eb6e823b125a64de314a8ee9791367c9a34d56af18d0"},
+    {file = "regex-2024.11.6-cp313-cp313-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:b583904576650166b3d920d2bcce13971f6f9e9a396c673187f49811b2769dc7"},
+    {file = "regex-2024.11.6-cp313-cp313-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:1c4de13f06a0d54fa0d5ab1b7138bfa0d883220965a29616e3ea61b35d5f5fc7"},
+    {file = "regex-2024.11.6-cp313-cp313-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:3cde6e9f2580eb1665965ce9bf17ff4952f34f5b126beb509fee8f4e994f143c"},
+    {file = "regex-2024.11.6-cp313-cp313-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:0d7f453dca13f40a02b79636a339c5b62b670141e63efd511d3f8f73fba162b3"},
+    {file = "regex-2024.11.6-cp313-cp313-musllinux_1_2_aarch64.whl", hash = "sha256:59dfe1ed21aea057a65c6b586afd2a945de04fc7db3de0a6e3ed5397ad491b07"},
+    {file = "regex-2024.11.6-cp313-cp313-musllinux_1_2_i686.whl", hash = "sha256:b97c1e0bd37c5cd7902e65f410779d39eeda155800b65fc4d04cc432efa9bc6e"},
+    {file = "regex-2024.11.6-cp313-cp313-musllinux_1_2_ppc64le.whl", hash = "sha256:f9d1e379028e0fc2ae3654bac3cbbef81bf3fd571272a42d56c24007979bafb6"},
+    {file = "regex-2024.11.6-cp313-cp313-musllinux_1_2_s390x.whl", hash = "sha256:13291b39131e2d002a7940fb176e120bec5145f3aeb7621be6534e46251912c4"},
+    {file = "regex-2024.11.6-cp313-cp313-musllinux_1_2_x86_64.whl", hash = "sha256:4f51f88c126370dcec4908576c5a627220da6c09d0bff31cfa89f2523843316d"},
+    {file = "regex-2024.11.6-cp313-cp313-win32.whl", hash = "sha256:63b13cfd72e9601125027202cad74995ab26921d8cd935c25f09c630436348ff"},
+    {file = "regex-2024.11.6-cp313-cp313-win_amd64.whl", hash = "sha256:2b3361af3198667e99927da8b84c1b010752fa4b1115ee30beaa332cabc3ef1a"},
+    {file = "regex-2024.11.6-cp38-cp38-macosx_10_9_universal2.whl", hash = "sha256:3a51ccc315653ba012774efca4f23d1d2a8a8f278a6072e29c7147eee7da446b"},
+    {file = "regex-2024.11.6-cp38-cp38-macosx_10_9_x86_64.whl", hash = "sha256:ad182d02e40de7459b73155deb8996bbd8e96852267879396fb274e8700190e3"},
+    {file = "regex-2024.11.6-cp38-cp38-macosx_11_0_arm64.whl", hash = "sha256:ba9b72e5643641b7d41fa1f6d5abda2c9a263ae835b917348fc3c928182ad467"},
+    {file = "regex-2024.11.6-cp38-cp38-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:40291b1b89ca6ad8d3f2b82782cc33807f1406cf68c8d440861da6304d8ffbbd"},
+    {file = "regex-2024.11.6-cp38-cp38-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:cdf58d0e516ee426a48f7b2c03a332a4114420716d55769ff7108c37a09951bf"},
+    {file = "regex-2024.11.6-cp38-cp38-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:a36fdf2af13c2b14738f6e973aba563623cb77d753bbbd8d414d18bfaa3105dd"},
+    {file = "regex-2024.11.6-cp38-cp38-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:d1cee317bfc014c2419a76bcc87f071405e3966da434e03e13beb45f8aced1a6"},
+    {file = "regex-2024.11.6-cp38-cp38-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:50153825ee016b91549962f970d6a4442fa106832e14c918acd1c8e479916c4f"},
+    {file = "regex-2024.11.6-cp38-cp38-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_12_x86_64.manylinux2010_x86_64.whl", hash = "sha256:ea1bfda2f7162605f6e8178223576856b3d791109f15ea99a9f95c16a7636fb5"},
+    {file = "regex-2024.11.6-cp38-cp38-musllinux_1_2_aarch64.whl", hash = "sha256:df951c5f4a1b1910f1a99ff42c473ff60f8225baa1cdd3539fe2819d9543e9df"},
+    {file = "regex-2024.11.6-cp38-cp38-musllinux_1_2_i686.whl", hash = "sha256:072623554418a9911446278f16ecb398fb3b540147a7828c06e2011fa531e773"},
+    {file = "regex-2024.11.6-cp38-cp38-musllinux_1_2_ppc64le.whl", hash = "sha256:f654882311409afb1d780b940234208a252322c24a93b442ca714d119e68086c"},
+    {file = "regex-2024.11.6-cp38-cp38-musllinux_1_2_s390x.whl", hash = "sha256:89d75e7293d2b3e674db7d4d9b1bee7f8f3d1609428e293771d1a962617150cc"},
+    {file = "regex-2024.11.6-cp38-cp38-musllinux_1_2_x86_64.whl", hash = "sha256:f65557897fc977a44ab205ea871b690adaef6b9da6afda4790a2484b04293a5f"},
+    {file = "regex-2024.11.6-cp38-cp38-win32.whl", hash = "sha256:6f44ec28b1f858c98d3036ad5d7d0bfc568bdd7a74f9c24e25f41ef1ebfd81a4"},
+    {file = "regex-2024.11.6-cp38-cp38-win_amd64.whl", hash = "sha256:bb8f74f2f10dbf13a0be8de623ba4f9491faf58c24064f32b65679b021ed0001"},
+    {file = "regex-2024.11.6-cp39-cp39-macosx_10_9_universal2.whl", hash = "sha256:5704e174f8ccab2026bd2f1ab6c510345ae8eac818b613d7d73e785f1310f839"},
+    {file = "regex-2024.11.6-cp39-cp39-macosx_10_9_x86_64.whl", hash = "sha256:220902c3c5cc6af55d4fe19ead504de80eb91f786dc102fbd74894b1551f095e"},
+    {file = "regex-2024.11.6-cp39-cp39-macosx_11_0_arm64.whl", hash = "sha256:5e7e351589da0850c125f1600a4c4ba3c722efefe16b297de54300f08d734fbf"},
+    {file = "regex-2024.11.6-cp39-cp39-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:5056b185ca113c88e18223183aa1a50e66507769c9640a6ff75859619d73957b"},
+    {file = "regex-2024.11.6-cp39-cp39-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:2e34b51b650b23ed3354b5a07aab37034d9f923db2a40519139af34f485f77d0"},
+    {file = "regex-2024.11.6-cp39-cp39-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:5670bce7b200273eee1840ef307bfa07cda90b38ae56e9a6ebcc9f50da9c469b"},
+    {file = "regex-2024.11.6-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:08986dce1339bc932923e7d1232ce9881499a0e02925f7402fb7c982515419ef"},
+    {file = "regex-2024.11.6-cp39-cp39-manylinux_2_5_i686.manylinux1_i686.manylinux_2_17_i686.manylinux2014_i686.whl", hash = "sha256:93c0b12d3d3bc25af4ebbf38f9ee780a487e8bf6954c115b9f015822d3bb8e48"},
+    {file = "regex-2024.11.6-cp39-cp39-manylinux_2_5_x86_64.manylinux1_x86_64.manylinux_2_12_x86_64.manylinux2010_x86_64.whl", hash = "sha256:764e71f22ab3b305e7f4c21f1a97e1526a25ebdd22513e251cf376760213da13"},
+    {file = "regex-2024.11.6-cp39-cp39-musllinux_1_2_aarch64.whl", hash = "sha256:f056bf21105c2515c32372bbc057f43eb02aae2fda61052e2f7622c801f0b4e2"},
+    {file = "regex-2024.11.6-cp39-cp39-musllinux_1_2_i686.whl", hash = "sha256:69ab78f848845569401469da20df3e081e6b5a11cb086de3eed1d48f5ed57c95"},
+    {file = "regex-2024.11.6-cp39-cp39-musllinux_1_2_ppc64le.whl", hash = "sha256:86fddba590aad9208e2fa8b43b4c098bb0ec74f15718bb6a704e3c63e2cef3e9"},
+    {file = "regex-2024.11.6-cp39-cp39-musllinux_1_2_s390x.whl", hash = "sha256:684d7a212682996d21ca12ef3c17353c021fe9de6049e19ac8481ec35574a70f"},
+    {file = "regex-2024.11.6-cp39-cp39-musllinux_1_2_x86_64.whl", hash = "sha256:a03e02f48cd1abbd9f3b7e3586d97c8f7a9721c436f51a5245b3b9483044480b"},
+    {file = "regex-2024.11.6-cp39-cp39-win32.whl", hash = "sha256:41758407fc32d5c3c5de163888068cfee69cb4c2be844e7ac517a52770f9af57"},
+    {file = "regex-2024.11.6-cp39-cp39-win_amd64.whl", hash = "sha256:b2837718570f95dd41675328e111345f9b7095d821bac435aac173ac80b19983"},
+    {file = "regex-2024.11.6.tar.gz", hash = "sha256:7ab159b063c52a0333c884e4679f8d7a85112ee3078fe3d9004b2dd875585519"},
 ]
 
 [[package]]
@@ -1558,13 +1624,13 @@ files = [
 
 [[package]]
 name = "starlette"
-version = "0.40.0"
+version = "0.41.3"
 description = "The little ASGI library that shines."
 optional = false
 python-versions = ">=3.8"
 files = [
-    {file = "starlette-0.40.0-py3-none-any.whl", hash = "sha256:c494a22fae73805376ea6bf88439783ecfba9aac88a43911b48c653437e784c4"},
-    {file = "starlette-0.40.0.tar.gz", hash = "sha256:1a3139688fb298ce5e2d661d37046a66ad996ce94be4d4983be019a23a04ea35"},
+    {file = "starlette-0.41.3-py3-none-any.whl", hash = "sha256:44cedb2b7c77a9de33a8b74b2b90e9f50d11fcf25d8270ea525ad71a25374ff7"},
+    {file = "starlette-0.41.3.tar.gz", hash = "sha256:0e4ab3d16522a255be6b28260b938eae2482f98ce5cc934cb08dce8dc3ba5835"},
 ]
 
 [package.dependencies]
@@ -1605,13 +1671,13 @@ tests = ["pytest", "pytest-cov"]
 
 [[package]]
 name = "tomli"
-version = "2.0.2"
+version = "2.1.0"
 description = "A lil' TOML parser"
 optional = false
 python-versions = ">=3.8"
 files = [
-    {file = "tomli-2.0.2-py3-none-any.whl", hash = "sha256:2ebe24485c53d303f690b0ec092806a085f07af5a5aa1464f3931eec36caaa38"},
-    {file = "tomli-2.0.2.tar.gz", hash = "sha256:d46d457a85337051c36524bc5349dd91b1877838e2979ac5ced3e710ed8a60ed"},
+    {file = "tomli-2.1.0-py3-none-any.whl", hash = "sha256:a5c57c3d1c56f5ccdf89f6523458f60ef716e210fc47c4cfb188c5ba473e0391"},
+    {file = "tomli-2.1.0.tar.gz", hash = "sha256:3f646cae2aec94e17d04973e4249548320197cfabdf130015d023de4b74d8ab8"},
 ]
 
 [[package]]
@@ -1732,13 +1798,13 @@ files = [
 
 [[package]]
 name = "werkzeug"
-version = "3.0.4"
+version = "3.0.6"
 description = "The comprehensive WSGI web application library."
 optional = false
 python-versions = ">=3.8"
 files = [
-    {file = "werkzeug-3.0.4-py3-none-any.whl", hash = "sha256:02c9eb92b7d6c06f31a782811505d2157837cea66aaede3e217c7c27c039476c"},
-    {file = "werkzeug-3.0.4.tar.gz", hash = "sha256:34f2371506b250df4d4f84bfe7b0921e4762525762bbd936614909fe25cd7306"},
+    {file = "werkzeug-3.0.6-py3-none-any.whl", hash = "sha256:1bc0c2310d2fbb07b1dd1105eba2f7af72f322e1e455f2f93c993bee8c8a5f17"},
+    {file = "werkzeug-3.0.6.tar.gz", hash = "sha256:a8dd59d4de28ca70471a34cba79bed5f7ef2e036a76b3ab0835474246eb41f8d"},
 ]
 
 [package.dependencies]
@@ -1749,13 +1815,13 @@ watchdog = ["watchdog (>=2.3)"]
 
 [[package]]
 name = "wheel"
-version = "0.44.0"
+version = "0.45.0"
 description = "A built-package format for Python"
 optional = false
 python-versions = ">=3.8"
 files = [
-    {file = "wheel-0.44.0-py3-none-any.whl", hash = "sha256:2376a90c98cc337d18623527a97c31797bd02bad0033d41547043a1cbfbe448f"},
-    {file = "wheel-0.44.0.tar.gz", hash = "sha256:a29c3f2817e95ab89aa4660681ad547c0e9547f20e75b0562fe7723c9a2a9d49"},
+    {file = "wheel-0.45.0-py3-none-any.whl", hash = "sha256:52f0baa5e6522155090a09c6bd95718cc46956d1b51d537ea5454249edb671c7"},
+    {file = "wheel-0.45.0.tar.gz", hash = "sha256:a57353941a3183b3d5365346b567a260a0602a0f8a635926a7dede41b94c674a"},
 ]
 
 [package.extras]
@@ -1783,4 +1849,4 @@ type = ["pytest-mypy"]
 [metadata]
 lock-version = "2.0"
 python-versions = "^3.8"
-content-hash = "cb82fb8a60ac82e9d0a5c351c89db723038ce3d9bab93301a5fc4f0ddca38457"
+content-hash = "d0780e5016179f1d34344691f73f54d4debbb6af0a2796b5a7a47123764a7472"
diff --git a/pyproject.toml b/pyproject.toml
index 9504a3a3..1c23f807 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -29,6 +29,7 @@ prometheus-client = "<1.0"
 future = "^1.0.0"
 PyYAML = ">=5.4,<7.0.0"
 pydantic = ">=2.0.0,<3.0.0"
+di = "^0.79.2"
 
 [tool.poetry.group.dev.dependencies]
 pytest = "^8.3.3"
@@ -47,6 +48,7 @@ mkdocs-material = "^9.5.39"
 starlette-prometheus = "^0.10.0"
 codecov = "^2.1.12"
 mkdocstrings = { version = "^0.26.1", extras = ["python"] }
+Faker = "^14.2.0"
 
 [build-system]
 requires = ["poetry-core>=1.0.0"]
diff --git a/scripts/test b/scripts/test
index a20ebb12..5cff7269 100755
--- a/scripts/test
+++ b/scripts/test
@@ -5,7 +5,7 @@ if [ -d '.venv' ] ; then
     export PREFIX=".venv/bin/"
 fi
 
-${PREFIX}pytest -x --cov-report term-missing --cov-report=xml:coverage.xml --cov=kstreams ${1-"./tests"} $2
+${PREFIX}pytest --cov-report term-missing --cov-report=xml:coverage.xml --cov=kstreams ${1-"./tests"} $2
 ${PREFIX}ruff check kstreams tests
 ${PREFIX}ruff format --check kstreams tests examples
-${PREFIX}mypy kstreams/
+${PREFIX}mypy kstreams/ tests
diff --git a/tests/_di/test_dependency_manager.py b/tests/_di/test_dependency_manager.py
new file mode 100644
index 00000000..716136e0
--- /dev/null
+++ b/tests/_di/test_dependency_manager.py
@@ -0,0 +1,97 @@
+from typing import Any, AsyncGenerator, Generator
+
+import pytest
+
+from kstreams._di.dependencies.core import StreamDependencyManager
+from kstreams.streams import Stream
+from kstreams.types import ConsumerRecord
+
+
+class AppWrapper:
+    """This is a fake class used to check if the ConsumerRecord is injected"""
+
+    def __init__(self) -> None:
+        self.foo = "bar"
+
+    async def consume(self, cr: ConsumerRecord) -> str:
+        return self.foo
+
+
+@pytest.fixture
+def di_cr(rand_consumer_record) -> Generator[ConsumerRecord, Any, None]:
+    """Dependency injected ConsumerRecord"""
+    yield rand_consumer_record()
+
+
+async def test_cr_is_injected(di_cr: ConsumerRecord):
+    async def user_fn(cr: ConsumerRecord) -> str:
+        cr.value = "hello"
+        return cr.value
+
+    stream_manager = StreamDependencyManager()
+    stream_manager._register_consumer_record()
+    stream_manager.solve_user_fn(user_fn)
+    content = await stream_manager.execute(di_cr)
+    assert content == "hello"
+
+
+async def test_cr_is_injected_in_class(di_cr: ConsumerRecord):
+    app = AppWrapper()
+    stream_manager = StreamDependencyManager()
+    stream_manager._register_consumer_record()
+    stream_manager.solve_user_fn(app.consume)
+    content = await stream_manager.execute(di_cr)
+    assert content == app.foo
+
+
+async def test_cr_generics_is_injected(di_cr: ConsumerRecord):
+    async def user_fn(cr: ConsumerRecord[Any, Any]) -> str:
+        cr.value = "hello"
+        return cr.value
+
+    stream_manager = StreamDependencyManager()
+    stream_manager._register_consumer_record()
+    stream_manager.solve_user_fn(user_fn)
+    content = await stream_manager.execute(di_cr)
+    assert content == "hello"
+
+
+async def test_cr_with_generator(di_cr: ConsumerRecord):
+    async def user_fn(cr: ConsumerRecord) -> AsyncGenerator[str, None]:
+        cr.value = "hello"
+        yield cr.value
+
+    stream_manager = StreamDependencyManager()
+    stream_manager._register_consumer_record()
+    stream_manager.solve_user_fn(user_fn)
+    content = await stream_manager.execute(di_cr)
+
+    assert content == "hello"
+
+
+async def test_stream(di_cr: ConsumerRecord):
+    async def user_fn(stream: Stream) -> str:
+        return stream.name
+
+    stream = Stream("my-topic", func=user_fn, name="stream_name")
+    stream_manager = StreamDependencyManager()
+    stream_manager._register_stream(stream)
+    stream_manager._register_consumer_record()
+    stream_manager.solve_user_fn(user_fn)
+    content = await stream_manager.execute(di_cr)
+    assert content == "stream_name"
+
+
+async def test_stream_and_consumer_record(di_cr: ConsumerRecord):
+    async def user_fn(stream: Stream, record: ConsumerRecord) -> tuple[str, str]:
+        return (stream.name, record.topic)
+
+    stream = Stream("my-topic", func=user_fn, name="stream_name")
+    stream_manager = StreamDependencyManager()
+    stream_manager._register_stream(stream)
+    stream_manager._register_consumer_record()
+    stream_manager.solve_user_fn(user_fn)
+    (stream_name, topic_name) = await stream_manager.execute(di_cr)
+
+    assert stream_name == "stream_name"
+    assert topic_name == di_cr.topic
diff --git a/tests/_di/test_hooks.py b/tests/_di/test_hooks.py
new file mode 100644
index 00000000..30e83ad8
--- /dev/null
+++ b/tests/_di/test_hooks.py
@@ -0,0 +1,75 @@
+import typing
+
+import pytest
+from di import Container
+from di.dependent import Dependent
+from di.executors import SyncExecutor
+
+from kstreams._di.dependencies.hooks import bind_by_generic
+
+KT = typing.TypeVar("KT")
+VT = typing.TypeVar("VT")
+
+
+class Record(typing.Generic[KT, VT]):
+    def __init__(self, key: KT, value: VT):
+        self.key = key
+        self.value = value
+
+
+def func_hinted(record: Record[str, int]) -> Record[str, int]:
+    return record
+
+
+def func_base(record: Record) -> Record:
+    return record
+
+
+@pytest.mark.parametrize(
+    "func",
+    [
+        func_hinted,
+        func_base,
+    ],
+)
+def test_bind_generic_ok(func: typing.Callable):
+    dep = Dependent(func)
+    container = Container()
+    container.bind(
+        bind_by_generic(
+            Dependent(lambda: Record("foo", 1), wire=False),
+            Record,
+        )
+    )
+    solved = container.solve(dep, scopes=[None])
+    with container.enter_scope(None) as state:
+        instance = solved.execute_sync(executor=SyncExecutor(), state=state)
+    assert isinstance(instance, Record)
+
+
+def func_str(record: str) -> str:
+    return record
+
+
+@pytest.mark.parametrize(
+    "func",
+    [
+        func_str,
+    ],
+)
+def test_bind_generic_unrelated(func: typing.Callable):
+    dep = Dependent(func)
+    container = Container()
+    container.bind(
+        bind_by_generic(
+            Dependent(lambda: Record("foo", 1), wire=False),
+            Record,
+        )
+    )
+    solved = container.solve(dep, scopes=[None])
+    with container.enter_scope(None) as state:
+        instance = solved.execute_sync(executor=SyncExecutor(), state=state)
+        print(type(instance))
+        print(instance)
+    assert not isinstance(instance, Record)
+    assert isinstance(instance, str)
diff --git a/tests/_di/test_param_headers.py b/tests/_di/test_param_headers.py
new file mode 100644
index 00000000..cef94960
--- /dev/null
+++ b/tests/_di/test_param_headers.py
@@ -0,0 +1,76 @@
+from typing import Callable
+
+import pytest
+
+from kstreams import FromHeader, Header
+from kstreams._di.dependencies.core import StreamDependencyManager
+from kstreams.exceptions import HeaderNotFound
+from kstreams.types import ConsumerRecord
+from kstreams.typing import Annotated
+
+RandConsumerRecordFixture = Callable[..., ConsumerRecord]
+
+
+async def test_from_headers_ok(rand_consumer_record: RandConsumerRecordFixture):
+    cr = rand_consumer_record(headers=(("event-type", "hello"),))
+
+    async def user_fn(event_type: FromHeader[str]) -> str:
+        return event_type
+
+    stream_manager = StreamDependencyManager()
+    stream_manager.solve_user_fn(user_fn)
+    header_content = await stream_manager.execute(cr)
+    assert header_content == "hello"
+
+
+async def test_from_header_not_found(rand_consumer_record: RandConsumerRecordFixture):
+    cr = rand_consumer_record(headers=(("event-type", "hello"),))
+
+    def user_fn(a_header: FromHeader[str]) -> str:
+        return a_header
+
+    stream_manager = StreamDependencyManager()
+    stream_manager.solve_user_fn(user_fn)
+    with pytest.raises(HeaderNotFound):
+        await stream_manager.execute(cr)
+
+
+@pytest.mark.xfail(reason="not implemenetd yet")
+async def test_from_headers_numbers(rand_consumer_record: RandConsumerRecordFixture):
+    cr = rand_consumer_record(headers=(("event-type", "1"),))
+
+    async def user_fn(event_type: FromHeader[int]) -> int:
+        return event_type
+
+    stream_manager = StreamDependencyManager()
+    stream_manager.solve_user_fn(user_fn)
+    header_content = await stream_manager.execute(cr)
+    assert header_content == 1
+
+
+async def test_headers_alias(rand_consumer_record: RandConsumerRecordFixture):
+    cr = rand_consumer_record(headers=(("EventType", "hello"),))
+
+    async def user_fn(event_type: Annotated[int, Header(alias="EventType")]) -> int:
+        return event_type
+
+    stream_manager = StreamDependencyManager()
+    stream_manager.solve_user_fn(user_fn)
+    header_content = await stream_manager.execute(cr)
+    assert header_content == "hello"
+
+
+async def test_headers_convert_underscores(
+    rand_consumer_record: RandConsumerRecordFixture,
+):
+    cr = rand_consumer_record(headers=(("event_type", "hello"),))
+
+    async def user_fn(
+        event_type: Annotated[int, Header(convert_underscores=False)],
+    ) -> int:
+        return event_type
+
+    stream_manager = StreamDependencyManager()
+    stream_manager.solve_user_fn(user_fn)
+    header_content = await stream_manager.execute(cr)
+    assert header_content == "hello"
diff --git a/tests/conftest.py b/tests/conftest.py
index 985194e4..eb2e291f 100644
--- a/tests/conftest.py
+++ b/tests/conftest.py
@@ -1,14 +1,21 @@
+import logging
 from collections import namedtuple
 from dataclasses import field
-from typing import Any, Dict, List, NamedTuple, Optional, Sequence, Tuple
+from typing import Any, Callable, Dict, List, NamedTuple, Optional, Sequence, Tuple
 
 import pytest
 import pytest_asyncio
+from faker import Faker
 from pytest_httpserver import HTTPServer
 
 from kstreams import clients, create_engine
+from kstreams.types import ConsumerRecord
 from kstreams.utils import create_ssl_context_from_mem
 
+# Silence faker DEBUG logs
+logger = logging.getLogger("faker")
+logger.setLevel(logging.INFO)
+
 
 class RecordMetadata(NamedTuple):
     offset: int = 1
@@ -195,3 +202,55 @@ class ConsumerRecord(NamedTuple):
         )
 
     return consumer_record
+
+
+@pytest.fixture
+def fake():
+    return Faker()
+
+
+@pytest.fixture()
+def rand_consumer_record(fake: Faker) -> Callable[..., ConsumerRecord]:
+    """A random consumer record generator.
+
+    You can inject this fixture in your test,
+    and then you can override the default values.
+
+    Example:
+
+    ```python
+    def test_my_consumer(rand_consumer_record):
+        rand_cr = rand_consumer_record()
+        custom_attrs_cr = rand_consumer_record(topic="my-topic", value="my-value")
+        # ...
+    ```
+    """
+
+    def generate(
+        topic: Optional[str] = None,
+        headers: Optional[Sequence[Tuple[str, bytes]]] = None,
+        partition: Optional[int] = None,
+        offset: Optional[int] = None,
+        timestamp: Optional[int] = None,
+        timestamp_type: Optional[int] = None,
+        key: Optional[Any] = None,
+        value: Optional[Any] = None,
+        checksum: Optional[int] = None,
+        serialized_key_size: Optional[int] = None,
+        serialized_value_size: Optional[int] = None,
+    ) -> ConsumerRecord:
+        return ConsumerRecord(
+            topic=topic or fake.slug(),
+            headers=headers or tuple(),
+            partition=partition or fake.pyint(max_value=10),
+            offset=offset or fake.pyint(max_value=99999999),
+            timestamp=timestamp or fake.unix_time(),
+            timestamp_type=timestamp_type or 1,
+            key=key or fake.pystr(),
+            value=value or fake.pystr().encode(),
+            checksum=checksum or fake.pystr(),
+            serialized_key_size=serialized_key_size or fake.pyint(max_value=10),
+            serialized_value_size=serialized_value_size or fake.pyint(max_value=10),
+        )
+
+    return generate
diff --git a/tests/test_monitor.py b/tests/test_monitor.py
index 0b94361b..bb013d98 100644
--- a/tests/test_monitor.py
+++ b/tests/test_monitor.py
@@ -20,62 +20,68 @@ async def my_coroutine(_):
     stream_engine.add_stream(stream=stream)
     await stream.start()
 
+    assert stream.consumer is not None
     await stream_engine.monitor.generate_consumer_metrics(stream.consumer)
     consumer = stream.consumer
 
     for topic_partition in consumer.assignment():
         # super ugly notation but for now is the only way to get the metrics
         met_committed = (
-            stream_engine.monitor.MET_COMMITTED.labels(
-                topic=topic_partition.topic,
-                partition=topic_partition.partition,
-                consumer_group=consumer._group_id,
-            )
-            .collect()[0]
+            list(
+                stream_engine.monitor.MET_COMMITTED.labels(
+                    topic=topic_partition.topic,
+                    partition=topic_partition.partition,
+                    consumer_group=consumer._group_id,
+                ).collect()
+            )[0]
             .samples[0]
             .value
         )
 
         met_position = (
-            stream_engine.monitor.MET_POSITION.labels(
-                topic=topic_partition.topic,
-                partition=topic_partition.partition,
-                consumer_group=consumer._group_id,
-            )
-            .collect()[0]
+            list(
+                stream_engine.monitor.MET_POSITION.labels(
+                    topic=topic_partition.topic,
+                    partition=topic_partition.partition,
+                    consumer_group=consumer._group_id,
+                ).collect()
+            )[0]
             .samples[0]
             .value
         )
 
         met_highwater = (
-            stream_engine.monitor.MET_HIGHWATER.labels(
-                topic=topic_partition.topic,
-                partition=topic_partition.partition,
-                consumer_group=consumer._group_id,
-            )
-            .collect()[0]
+            list(
+                stream_engine.monitor.MET_HIGHWATER.labels(
+                    topic=topic_partition.topic,
+                    partition=topic_partition.partition,
+                    consumer_group=consumer._group_id,
+                ).collect()
+            )[0]
             .samples[0]
             .value
         )
 
         met_lag = (
-            stream_engine.monitor.MET_LAG.labels(
-                topic=topic_partition.topic,
-                partition=topic_partition.partition,
-                consumer_group=consumer._group_id,
-            )
-            .collect()[0]
+            list(
+                stream_engine.monitor.MET_LAG.labels(
+                    topic=topic_partition.topic,
+                    partition=topic_partition.partition,
+                    consumer_group=consumer._group_id,
+                ).collect()
+            )[0]
             .samples[0]
             .value
         )
 
         met_position_lag = (
-            stream_engine.monitor.MET_POSITION_LAG.labels(
-                topic=topic_partition.topic,
-                partition=topic_partition.partition,
-                consumer_group=consumer._group_id,
-            )
-            .collect()[0]
+            list(
+                stream_engine.monitor.MET_POSITION_LAG.labels(
+                    topic=topic_partition.topic,
+                    partition=topic_partition.partition,
+                    consumer_group=consumer._group_id,
+                ).collect()
+            )[0]
             .samples[0]
             .value
         )
@@ -135,56 +141,61 @@ async def my_coroutine(_):
     for topic_partition in consumer.assignment():
         # super ugly notation but for now is the only way to get the metrics
         met_committed = (
-            stream_engine.monitor.MET_COMMITTED.labels(
-                topic=topic_partition.topic,
-                partition=topic_partition.partition,
-                consumer_group=consumer._group_id,
-            )
-            .collect()[0]
+            list(
+                stream_engine.monitor.MET_COMMITTED.labels(
+                    topic=topic_partition.topic,
+                    partition=topic_partition.partition,
+                    consumer_group=consumer._group_id,
+                ).collect()
+            )[0]
             .samples[0]
             .value
         )
 
         met_position = (
-            stream_engine.monitor.MET_POSITION.labels(
-                topic=topic_partition.topic,
-                partition=topic_partition.partition,
-                consumer_group=consumer._group_id,
-            )
-            .collect()[0]
+            list(
+                stream_engine.monitor.MET_POSITION.labels(
+                    topic=topic_partition.topic,
+                    partition=topic_partition.partition,
+                    consumer_group=consumer._group_id,
+                ).collect()
+            )[0]
             .samples[0]
             .value
         )
 
         met_highwater = (
-            stream_engine.monitor.MET_HIGHWATER.labels(
-                topic=topic_partition.topic,
-                partition=topic_partition.partition,
-                consumer_group=consumer._group_id,
-            )
-            .collect()[0]
+            list(
+                stream_engine.monitor.MET_HIGHWATER.labels(
+                    topic=topic_partition.topic,
+                    partition=topic_partition.partition,
+                    consumer_group=consumer._group_id,
+                ).collect()
+            )[0]
             .samples[0]
             .value
         )
 
         met_lag = (
-            stream_engine.monitor.MET_LAG.labels(
-                topic=topic_partition.topic,
-                partition=topic_partition.partition,
-                consumer_group=consumer._group_id,
-            )
-            .collect()[0]
+            list(
+                stream_engine.monitor.MET_LAG.labels(
+                    topic=topic_partition.topic,
+                    partition=topic_partition.partition,
+                    consumer_group=consumer._group_id,
+                ).collect()
+            )[0]
             .samples[0]
             .value
         )
 
         met_position_lag = (
-            stream_engine.monitor.MET_POSITION_LAG.labels(
-                topic=topic_partition.topic,
-                partition=topic_partition.partition,
-                consumer_group=consumer._group_id,
-            )
-            .collect()[0]
+            list(
+                stream_engine.monitor.MET_POSITION_LAG.labels(
+                    topic=topic_partition.topic,
+                    partition=topic_partition.partition,
+                    consumer_group=consumer._group_id,
+                ).collect()
+            )[0]
             .samples[0]
             .value
         )
@@ -200,9 +211,9 @@ async def my_coroutine(_):
             met_position_lag == consumer.highwater(topic_partition) - consumer_position
         )
 
-    assert len(stream_engine.monitor.MET_POSITION_LAG.collect()[0].samples) == 2
+    assert len(list(stream_engine.monitor.MET_POSITION_LAG.collect())[0].samples) == 2
     await stream_engine.remove_stream(stream)
-    assert len(stream_engine.monitor.MET_POSITION_LAG.collect()[0].samples) == 0
+    assert len(list(stream_engine.monitor.MET_POSITION_LAG.collect())[0].samples) == 0
 
 
 @pytest.mark.asyncio
@@ -223,6 +234,6 @@ async def my_coroutine(_):
     stream_engine.add_stream(stream=stream)
     await stream.start()
 
-    assert len(stream_engine.monitor.MET_POSITION_LAG.collect()[0].samples) == 0
+    assert len(list(stream_engine.monitor.MET_POSITION_LAG.collect())[0].samples) == 0
     await stream_engine.remove_stream(stream)
     assert "Metrics for consumer with group-id: my-group not found" in caplog.text
diff --git a/tests/test_streams.py b/tests/test_streams.py
index 9f05a5ae..29cdd224 100644
--- a/tests/test_streams.py
+++ b/tests/test_streams.py
@@ -339,7 +339,6 @@ async def streaming_fn(_):
             Consumer.stop.assert_awaited()
 
 
-@pytest.mark.asyncio
 async def test_stream_decorates_properly(stream_engine: StreamEngine):
     topic = "local--hello-kpn"