From d417b44455b3f43cdcde8a1d2bafb200e426d30e Mon Sep 17 00:00:00 2001 From: Julien Danjou Date: Tue, 13 Dec 2016 15:00:42 +0100 Subject: [PATCH] coordination: allow to pass capabilities in join_group_create() Change-Id: Ie2c18740759b9b4f24ac802f659ebcaa830c0679 --- tooz/coordination.py | 6 +++--- 1 file 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: