Skip to content

Conversation

@jeroenmaelbrancke
Copy link
Contributor

Fixed this issue by using the /ovs/framework/messagequeue/endpoints.
Code based on ovs/celery_run.py.
@khenderick could you please do a code review of this?
Did you already test the multi-node string?
Should i make a ticket to get all the rabbitmq ips in the endpoints field?

etcdctl get /ovs/framework/messagequeue
{"endpoints": ["10.100.199.1:5672"], "protocol": "amqp", "queues": {"storagedriver": "volumerouter"}, "user": "", "password": "", "metadata": {"internal": true}}

Fixed this issue by using the /ovs/framework/messagequeue/endpoints.
Code based on ovs/celery_run.py.
@khenderick
Copy link
Contributor

Alternative (create a tasks on his own worker).
The worker will update the heartbeat celery key with the timestamp when the task is created.
Alternative (create a tasks on his own worker).
The worker will update the heartbeat celery key with the timestamp when the task is created.
@jeroenmaelbrancke
Copy link
Contributor Author

@khenderick could you please do a code review of this?
Changed a couple of things cause celery inspect ping doesn't work with multiple brokers....

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants