We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents dcb239e + 4bfcdbb commit 2b2c01eCopy full SHA for 2b2c01e
packit_service/worker/handlers/abstract.py
@@ -548,6 +548,9 @@ def check_rate_limit_remaining(self) -> None:
548
)
549
# Increment the metric for tasks enqueued to the rate-limited queue
550
self.pushgateway.rate_limited_tasks_enqueued.inc()
551
+ # Push metrics immediately since we're about to raise an exception
552
+ # that will prevent the normal push() call in run_job()
553
+ self.pushgateway.push()
554
# Use apply_async to reschedule the task to the rate-limited queue
555
# retry() isn't working, the chosen queue is the one defined in the task definition,
556
# not the one passed to retry()
0 commit comments