Fixed calls to do_badger to use keyword arguments for role(s)
- updated call to pass multiple roles at once - updated call to pass single role with keyword arg This requires Pillar 87afbc52f6c7d5eb63f0da745625d05b01e81783
This commit is contained in:
@@ -111,8 +111,8 @@ class CloudExtension(PillarExtension):
|
|||||||
# Avoid infinite loops while we're changing the user's roles.
|
# Avoid infinite loops while we're changing the user's roles.
|
||||||
service.signal_user_changed_role.disconnect(self._user_changed_role)
|
service.signal_user_changed_role.disconnect(self._user_changed_role)
|
||||||
try:
|
try:
|
||||||
for role in linked_roles:
|
if linked_roles:
|
||||||
service.do_badger(action, role, user_id=user['_id'])
|
service.do_badger(action, roles=linked_roles, user_id=user['_id'])
|
||||||
finally:
|
finally:
|
||||||
service.signal_user_changed_role.connect(self._user_changed_role)
|
service.signal_user_changed_role.connect(self._user_changed_role)
|
||||||
|
|
||||||
|
@@ -71,7 +71,7 @@ def reconcile_subscribers():
|
|||||||
action = 'grant'
|
action = 'grant'
|
||||||
|
|
||||||
with lock:
|
with lock:
|
||||||
service.do_badger(action, 'subscriber', user_id=user['_id'])
|
service.do_badger(action, role='subscriber', user_id=user['_id'])
|
||||||
|
|
||||||
with concurrent.futures.ThreadPoolExecutor(max_workers=10) as executor:
|
with concurrent.futures.ThreadPoolExecutor(max_workers=10) as executor:
|
||||||
future_to_user = {executor.submit(do_user, idx, user): user
|
future_to_user = {executor.submit(do_user, idx, user): user
|
||||||
|
Reference in New Issue
Block a user