fix

Author: lesnik512

tests/test_concurrent_processing.py

@@ -56,7 +56,7 @@ def is_healthy(self) -> bool:
 
 
 @pytest.fixture(autouse=True)
-def reset_singleton() -> typing.Generator[None]:
+def reset_singleton() -> typing.Iterator[None]:
     KafkaConcurrentHandler._instance = None
     KafkaConcurrentHandler._initialized = False
     yield

tests/test_middleware.py

@@ -17,7 +17,7 @@
 
 
 @pytest.fixture(autouse=True)
-def reset_singleton() -> typing.Generator[None]:
+def reset_singleton() -> typing.Iterator[None]:
     KafkaConcurrentHandler._instance = None
     KafkaConcurrentHandler._initialized = False
     yield