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 ae3d3b6 commit b674457Copy full SHA for b674457
taskiq/middlewares/smart_retry_middleware.py
@@ -61,6 +61,14 @@ def __init__(
61
self.max_delay_exponent = max_delay_exponent
62
self.schedule_source = schedule_source
63
64
+ if schedule_source is not None and not isinstance(
65
+ schedule_source,
66
+ ScheduleSource,
67
+ ):
68
+ raise TypeError(
69
+ "schedule_source must be an instance of ScheduleSource or None",
70
+ )
71
+
72
def is_retry_on_error(self, message: TaskiqMessage) -> bool:
73
"""
74
Check if retry is enabled for this task.
0 commit comments