diff --git a/redis_timers/timers.py b/redis_timers/timers.py index 35ec1e9..2533bfa 100644 --- a/redis_timers/timers.py +++ b/redis_timers/timers.py @@ -8,6 +8,7 @@ import pydantic from redis import asyncio as aioredis +from redis.asyncio import Redis from redis.exceptions import LockError from redis_timers import settings @@ -31,7 +32,7 @@ class Timers: def __init__( self, *, - redis_client: "aioredis.Redis[str]", + redis_client: Redis, # type: ignore[type-arg] context: dict[str, typing.Any], routers: list[Router] | None = None, ) -> None: @@ -71,7 +72,7 @@ async def _handle_one_timer(self, timer_key: str) -> None: raw_payload = await self.redis_client.hget(settings.TIMERS_PAYLOADS_KEY, timer_key) if not raw_payload: - logger.error(f"No payload found, {timer_key=}") + logger.debug(f"No payload found, seems like it was removed {timer_key=}") return try: diff --git a/tests/test_timers.py b/tests/test_timers.py index 5dbc4dd..e740f91 100644 --- a/tests/test_timers.py +++ b/tests/test_timers.py @@ -184,7 +184,7 @@ async def test_handle_ready_timer_no_handler(timers_instance: Timers, caplog: py async def test_handle_ready_timer_no_payload(timers_instance: Timers, caplog: pytest.LogCaptureFixture) -> None: - caplog.set_level(logging.INFO) + caplog.set_level(logging.DEBUG) payload = SomePayloadModel(message="ready_timer", count=42) await timers_instance.set_timer( topic="some_topic",