Revision cc5e8965 snf-astakos-app/astakos/im/endpoints/qh.py
b/snf-astakos-app/astakos/im/endpoints/qh.py | ||
---|---|---|
235 | 235 |
return set_quota(payload) |
236 | 236 |
|
237 | 237 |
def register_services(services): |
238 |
payload = list(CreateEntityPayload( |
|
239 |
entity=service, |
|
240 |
owner='system', |
|
241 |
key=ENTITY_KEY, |
|
242 |
ownerkey='') for service in set(services)) |
|
243 |
return create_entity(payload) |
|
238 |
def payload(services): |
|
239 |
return list(CreateEntityPayload( |
|
240 |
entity=service, |
|
241 |
owner='system', |
|
242 |
key=ENTITY_KEY, |
|
243 |
ownerkey='') |
|
244 |
for service in set(services)) |
|
245 |
|
|
246 |
if not services: |
|
247 |
return |
|
248 |
existing = create_entity(payload(services)) |
|
249 |
if 0 < len(existing) < len(services): |
|
250 |
nonexisting = [s for i, s in enumerate(services) |
|
251 |
if i not in existing] |
|
252 |
r = create_entity(payload(nonexisting)) |
|
253 |
if r: |
|
254 |
failed = [s for i, s in enumerate(nonexisting) |
|
255 |
if i in r] |
|
256 |
m = "Failed to register services: %s" % (failed,) |
|
257 |
raise RuntimeError(m) |
|
244 | 258 |
|
245 | 259 |
def register_resources(resources): |
246 | 260 |
try: |
Also available in: Unified diff