pass on partitions

join_partition_group allows you to declare partitions, so we should
pass that info on.

Change-Id: I2fdf817d42e56e99c4804021981d41e768c7fdd5
This commit is contained in:
gord chung 2017-03-09 17:29:05 +00:00
parent 1009c620f4
commit a73ca9f0eb
1 changed files with 1 additions and 1 deletions

View File

@ -274,7 +274,7 @@ class CoordinationDriver(object):
"""
self.join_group_create(
group_id, capabilities=utils.dumps({'weight': weight}))
return partitioner.Partitioner(self, group_id)
return partitioner.Partitioner(self, group_id, partitions=partitions)
def leave_partitioned_group(self, partitioner):
"""Leave a partitioned group.