Skip to content

Commit 13a000c

Browse files
committed
start adopting "executions" for async create network
1 parent 0892b54 commit 13a000c

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

netfoundry/network_group.py

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -243,21 +243,17 @@ def create_network(self, name: str, network_group_id: str = None, location: str
243243
raise RuntimeError(f"got unexpected HTTP code {STATUS_CODES._codes[response_code][0].upper()} ({response_code}) and response {response.text}")
244244

245245
try:
246-
process_executions = resource['_links'].get('process-executions')
247-
if isinstance(process_executions, list):
248-
find_executions_url = process_executions[0]['href']
249-
else:
250-
find_executions_url = process_executions['href']
246+
executions_link = resource['_links']['executions']['href']
251247
processes = list()
252248
process_id = None
253-
for i in find_generic_resources(url=find_executions_url, headers=headers, embedded=NET_RESOURCES['process-executions']._embedded, proxies=self.proxies, verify=self.verify):
249+
for i in find_generic_resources(url=executions_link, headers=headers, embedded=NET_RESOURCES['executions']._embedded, proxies=self.proxies, verify=self.verify):
254250
processes.extend(i)
255251
for process in processes:
256252
if process['name'].startswith('Create Network'):
257253
process_id = process['id']
258254
break
259255
if wait and process_id:
260-
self.Networks.wait_for_process(process_id, RESOURCES["process-executions"].status_symbols['complete'], wait=wait, sleep=sleep)
256+
self.Networks.wait_for_process(process_id, RESOURCES["executions"].status_symbols['complete'], wait=wait, sleep=sleep)
261257
resource = self.get_resource_by_id(type="network", id=resource['id'])
262258
else:
263259
self.logger.warning("not configured to wait or no process_id found in list of executions")

0 commit comments

Comments
 (0)