|
1 | 1 | import collections |
2 | 2 | import functools |
3 | 3 | import logging |
4 | | -import random |
5 | 4 | from datetime import timedelta |
6 | 5 | from functools import partial |
7 | 6 |
|
@@ -90,21 +89,17 @@ def sql_fetch_all(sql_backend): |
90 | 89 |
|
91 | 90 |
|
92 | 91 | @pytest.fixture |
93 | | -def user_pool(ws): |
94 | | - return list(ws.users.list(filter="displayName sw 'test-user-'", attributes="id, userName, displayName")) |
95 | | - |
96 | | - |
97 | | -@pytest.fixture |
98 | | -def make_ucx_group(make_random, make_group, make_acc_group, user_pool): |
99 | | - assert ( |
100 | | - len(user_pool) >= 1 |
101 | | - ), "must have 'test-user-*' test users with id, userName and displayName in your test workspace" |
102 | | - |
103 | | - def inner(): |
104 | | - display_name = f"ucx_{make_random(4)}" |
105 | | - members = [_.id for _ in random.choices(user_pool, k=random.randint(1, 40))] |
106 | | - ws_group = make_group(display_name=display_name, members=members, entitlements=["allow-cluster-create"]) |
107 | | - acc_group = make_acc_group(display_name=display_name, members=members) |
| 92 | +def make_ucx_group(make_random, make_group, make_acc_group, make_user): |
| 93 | + def inner(workspace_group_name=None, account_group_name=None): |
| 94 | + random_name = f"ucx_{make_random(4)}" |
| 95 | + if not workspace_group_name: |
| 96 | + workspace_group_name = random_name |
| 97 | + if not account_group_name: |
| 98 | + account_group_name = random_name |
| 99 | + user = make_user() |
| 100 | + members = [user.id] |
| 101 | + ws_group = make_group(display_name=workspace_group_name, members=members, entitlements=["allow-cluster-create"]) |
| 102 | + acc_group = make_acc_group(display_name=account_group_name, members=members) |
108 | 103 | return ws_group, acc_group |
109 | 104 |
|
110 | 105 | return inner |
|
0 commit comments