We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6b08205 commit 01b3f8fCopy full SHA for 01b3f8f
taskiq/middlewares/smart_retry_middleware.py
@@ -1,9 +1,7 @@
1
-from __future__ import annotations
2
-
3
import datetime
4
import random
5
from logging import getLogger
6
-from typing import Any
+from typing import Any, Optional
7
8
from taskiq import ScheduleSource
9
from taskiq.abc.middleware import TaskiqMiddleware
@@ -36,7 +34,7 @@ def __init__(
36
34
use_jitter: bool = False,
37
35
use_delay_exponent: bool = False,
38
max_delay_exponent: float = 60,
39
- schedule_source: ScheduleSource | None = None,
+ schedule_source: Optional[ScheduleSource] = None,
40
) -> None:
41
"""
42
Initialize retry middleware.
0 commit comments