reap all nodes that havn't checked in

* Before this change we would exclude the reaping of new nodes. With
this change, new nodes will be considered for reaping just like old
nodes.
This commit is contained in:
chris meyers 2018-03-01 11:21:54 -05:00
parent 8d57b84251
commit e94bd128b8

View File

@ -342,8 +342,6 @@ def cluster_node_heartbeat(self):
stop_local_services(['uwsgi', 'celery', 'beat', 'callback'], communicate=False)
raise RuntimeError("Shutting down.")
for other_inst in lost_instances:
if other_inst.capacity == 0:
continue
try:
other_inst.capacity = 0
other_inst.save(update_fields=['capacity'])