Merge "Don't heartbeat manually in the cloudkitty orchestrator"
This commit is contained in:
@@ -258,7 +258,7 @@ class Orchestrator(object):
|
|||||||
self.coord = coordination.get_coordinator(
|
self.coord = coordination.get_coordinator(
|
||||||
CONF.orchestrator.coordination_url,
|
CONF.orchestrator.coordination_url,
|
||||||
uuidutils.generate_uuid().encode('ascii'))
|
uuidutils.generate_uuid().encode('ascii'))
|
||||||
self.coord.start()
|
self.coord.start(start_heart=True)
|
||||||
|
|
||||||
def _lock(self, tenant_id):
|
def _lock(self, tenant_id):
|
||||||
lock_name = b"cloudkitty-" + str(tenant_id).encode('ascii')
|
lock_name = b"cloudkitty-" + str(tenant_id).encode('ascii')
|
||||||
@@ -308,7 +308,6 @@ class Orchestrator(object):
|
|||||||
|
|
||||||
lock.release()
|
lock.release()
|
||||||
|
|
||||||
self.coord.heartbeat()
|
|
||||||
# NOTE(sheeprine): Slow down looping if all tenants are
|
# NOTE(sheeprine): Slow down looping if all tenants are
|
||||||
# being processed
|
# being processed
|
||||||
eventlet.sleep(1)
|
eventlet.sleep(1)
|
||||||
|
@@ -0,0 +1,5 @@
|
|||||||
|
---
|
||||||
|
fixes:
|
||||||
|
- |
|
||||||
|
cloudkitty-processor crashes which happened when using distributed
|
||||||
|
tooz locks have been fixed.
|
Reference in New Issue
Block a user