diff --git a/dramatiq/middleware/retries.py b/dramatiq/middleware/retries.py index e222443e..a54c8471 100644 --- a/dramatiq/middleware/retries.py +++ b/dramatiq/middleware/retries.py @@ -96,8 +96,6 @@ def after_process_message(self, broker, message, *, result=None, exception=None) message.options["retries"] += 1 message.options["traceback"] = traceback.format_exc(limit=30) - - # Record in message options time at which it is requeued message.options["requeue_timestamp"] = int(time.time() * 1000) max_retries = message.options.get("max_retries") or actor.options.get("max_retries", self.max_retries)