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 e335493 commit ae3d3b6Copy full SHA for ae3d3b6
taskiq/middlewares/smart_retry_middleware.py
@@ -103,7 +103,9 @@ async def on_send(
103
delay: float,
104
) -> None:
105
"""Execute the task with a delay."""
106
- if isinstance(self.schedule_source, ScheduleSource):
+ if self.schedule_source is None:
107
+ await kicker.with_labels(delay=delay).kiq(*message.args, **message.kwargs)
108
+ else:
109
target_time = datetime.datetime.now(datetime.UTC) + datetime.timedelta(
110
seconds=delay,
111
)
@@ -113,8 +115,6 @@ async def on_send(
113
115
*message.args,
114
116
**message.kwargs,
117
- else:
- await kicker.with_labels(delay=delay).kiq(*message.args, **message.kwargs)
118
119
async def on_error(
120
self,
0 commit comments