summaryrefslogtreecommitdiff
path: root/tooz/coordination.py
diff options
context:
space:
mode:
authorJulien Danjou <julien@danjou.info>2016-12-13 15:00:42 +0100
committerJulien Danjou <julien@danjou.info>2016-12-13 15:26:20 +0100
commitd417b44455b3f43cdcde8a1d2bafb200e426d30e (patch)
treef271c37055f5f42e7d679df66c990624698bc239 /tooz/coordination.py
parent10b677dc5225208601e0a752ca447db9d103a591 (diff)
downloadtooz-d417b44455b3f43cdcde8a1d2bafb200e426d30e.tar.gz
coordination: allow to pass capabilities in join_group_create()
Change-Id: Ie2c18740759b9b4f24ac802f659ebcaa830c0679
Diffstat (limited to 'tooz/coordination.py')
-rwxr-xr-xtooz/coordination.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/tooz/coordination.py b/tooz/coordination.py
index 7990bf7..040f007 100755
--- a/tooz/coordination.py
+++ b/tooz/coordination.py
@@ -463,7 +463,7 @@ class CoordinationDriver(object):
raise tooz.NotImplemented
@_retry.retry()
- def join_group_create(self, group_id):
+ def join_group_create(self, group_id, capabilities=b""):
"""Join a group and create it if necessary.
If the group cannot be joined because it does not exist, it is created
@@ -474,9 +474,9 @@ class CoordinationDriver(object):
if another member is creating/deleting the group at the same time.
:param group_id: Identifier of the group to join and create
-
+ :param capabilities: the capabilities of the joined member
"""
- req = self.join_group(group_id)
+ req = self.join_group(group_id, capabilities)
try:
req.get()
except GroupNotCreated: