Commit b18c3c38 authored by Elger Jonker's avatar Elger Jonker

explain acks_late in autoscaling

parent 87021a85
Pipeline #35067801 passed with stages
in 22 minutes and 37 seconds
......@@ -56,6 +56,9 @@ def perform_autoscale(containergroup_name, scan_queue):
maximize(cg)
return
# you don't know if there are still running tasks. You also can't inspect it
# therefore we're using acks_late in celery to make sure that when this number is 0
# all tasks have been performed (successfully)
if stat['name'] == scan_queue and stat['messages'] == 0:
minimize(cg)
return
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment