code: def _wait_for_async(conn, request_id):
      '''
      Helper function for azure tests
      '''
      count = 0
      log.debug('Waiting for asynchronous operation to complete')
      result = conn.get_operation_status(request_id)
      while result.status == 'InProgress':
          count = count + 1
          if count > 120:
              raise ValueError('Timed out waiting for asynchronous operation to complete.')
          time.sleep(5)
          result = conn.get_operation_status(request_id)
  
      if result.status != 'Succeeded':
          raise AzureException('Operation failed. {message} ({code})'
                                  .format(message=result.error.message,
                                          code=result.error.code)f _wait_for_async(conn, request_id):
      '''
      Helper function for azure tests
      '''
      count = 0
      log.debug('Waiting for asynchronous operation to complete')
      result = conn.get_operation_status(request_id)
      while result.status == 'InProgress':
          count = count + 1
          if count > 120:
              raise ValueError('Timed out waiting for asynchronous operation to complete.')
          time.sleep(5)
          result = conn.get_operation_status(request_id)
  
      if result.status != 'Succeeded':
          raise AzureException('Operation failed. {message} ({code})'
                                  .format(message=result.error.message,
                                          code=result.error.code))
docs: Helper function for azure tests