in ADTTools/RecreateAdtInstance/main.py [0:0]
def create_endpoints():
num_endpoints = len(endpoints)
logger.info("Recreating %d endpoint(s).", num_endpoints)
start_time = round(time.time() * 1000)
updated_endpoints = list()
for endpoint in endpoints:
updated_endpoint = dt_resource_client.digital_twins_endpoint.begin_create_or_update(
resource_group_name=resource_group,
resource_name=instance_name,
endpoint_name=endpoint.name,
endpoint_description=DigitalTwinsEndpointResource(properties=map_endpoint(endpoint))
)
updated_endpoints.append(updated_endpoint)
spinner = Spinner.new("Creating Endpoints.")
spinner.start()
num_complete = 0
while True:
for index in range(0, num_endpoints):
current_request = updated_endpoints[index]
if current_request is None:
continue
if current_request.done():
updated_endpoints[index] = None
num_complete += 1
spinner.text = f"Creating Endpoints. {num_complete}/{num_endpoints}"
if num_complete is num_endpoints:
break
time.sleep(0.1)
end_time = round(time.time() * 1000)
spinner.stop()
return end_time - start_time