diff options
| author | Julien Danjou <julien@danjou.info> | 2016-12-13 15:00:42 +0100 |
|---|---|---|
| committer | Julien Danjou <julien@danjou.info> | 2016-12-13 15:26:20 +0100 |
| commit | d417b44455b3f43cdcde8a1d2bafb200e426d30e (patch) | |
| tree | f271c37055f5f42e7d679df66c990624698bc239 /tooz/coordination.py | |
| parent | 10b677dc5225208601e0a752ca447db9d103a591 (diff) | |
| download | tooz-d417b44455b3f43cdcde8a1d2bafb200e426d30e.tar.gz | |
coordination: allow to pass capabilities in join_group_create()
Change-Id: Ie2c18740759b9b4f24ac802f659ebcaa830c0679
Diffstat (limited to 'tooz/coordination.py')
| -rwxr-xr-x | tooz/coordination.py | 6 |
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: |
