Add on_stream_state_change retries

src/core/broker.py

@@ -1,4 +1,5 @@
 from taskiq import TaskiqScheduler
+from taskiq.middlewares.retry_middleware import SimpleRetryMiddleware
 from taskiq.schedule_sources import LabelScheduleSource
 from taskiq_redis import ListQueueBroker, RedisAsyncResultBackend
 
@@ -6,6 +7,9 @@ from core.config import config
 
 
 broker = ListQueueBroker(url=config.REDIS_URI) \
+    .with_middlewares(
+        SimpleRetryMiddleware(default_retry_count=5)
+    ) \
     .with_result_backend(RedisAsyncResultBackend(
         redis_url=config.REDIS_URI,
         result_ex_time=60 * 60 * 24 * 7,

src/modules/stream_notifications/tasks.py

@@ -8,7 +8,10 @@ from .watcher import StateWatcher
 from .twitch.authorize import authorize
 
 
-@broker.task("stream_notifications.twitch.on_stream_state_change")
+@broker.task(
+    "stream_notifications.twitch.on_stream_state_change",
+    retry_on_error=True
+)
 async def on_stream_state_change(
     streamer_id: int, new_state: State | None = None
 ):