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 87feb04 commit bbc74f9Copy full SHA for bbc74f9
taskiq/middlewares/smart_retry_middleware.py
@@ -107,7 +107,12 @@ async def on_send(
107
target_time = datetime.datetime.now(datetime.UTC) + datetime.timedelta(
108
seconds=delay,
109
)
110
- await kicker.schedule_by_time(self.schedule_source, target_time)
+ await kicker.schedule_by_time(
111
+ self.schedule_source,
112
+ target_time,
113
+ *message.args,
114
+ **message.kwargs,
115
+ )
116
else:
117
await kicker.with_labels(delay=delay).kiq(*message.args, **message.kwargs)
118
0 commit comments