Merge pull request #1411 from chrismeyersfsu/early_first_heartbeat

call node init procedures as early as possible
This commit is contained in:
Chris Meyers 2018-03-01 13:01:37 -05:00 committed by GitHub
commit 8c1ec37c80
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -225,6 +225,10 @@ def handle_ha_toplogy_worker_ready(sender, **kwargs):
logger.info("Workers on tower node '{}' unsubscribed from queues {} and subscribed to queues {}"
.format(instance.hostname, removed_queues, added_queues))
# Expedite the first hearbeat run so a node comes online quickly.
cluster_node_heartbeat.apply([])
apply_cluster_membership_policies.apply([])
@celeryd_init.connect
def handle_update_celery_routes(sender=None, conf=None, **kwargs):