code: def _launch_instance(self):
          
          self.running_instance_id = ipa_utils.generate_instance_name(
              'azure-ipa-test'
          )
          self.logger.debug('ID of instance: %s' % self.running_instance_id)
          self._set_default_resource_names()
  
          try:
              # Try block acts as a transaction. If an exception is raised
              # attempt to cleanup the resource group and all created resources.
  
              # Create resource group.
              self._create_resource_group(self.region, self.running_instance_id)
  
              if self.subnet_id:
                  # Use existing vnet/subnet.
                  subnet = self.network.subnets.get(
                      self.vnet_resource_group, self.vnet_name, self.subnet_id
                  )
              else:
                  self.subnet_id = ''.join([self.running_instance_id, '-subnet'])
                  self.vnet_name = ''.join([self.running_instance_id, '-vnet'])
  
                  # Create new vnet
                  self._create_virtual_network(
                      self.region, self.running_instance_id, self.vnet_name
                  )
  
                  # Create new subnet in new vnet
                  subnet = self._create_subnet(
                      self.running_instance_id, self.subnet_id, self.vnet_name
                  )
  
              # Setup interface and public ip in resource group.
              public_ip = self._create_public_ip(
                  self.public_ip_name, self.running_instance_id, self.region
              )
              interface = self._create_network_interface(
                  self.ip_config_name, self.nic_name, public_ip, self.region,
                  self.running_instance_id, subnet, self.accelerated_networking
              )
  
              # Get dictionary of VM parameters and create instance.
              vm_config = self._create_vm_config(interface)
              self._create_vm(vm_config)
          except Exception:
              try:
                  self._terminate_instance()
              except Exception:
                  pass
              raise
          else:
              # Ensure VM is in the running state.
              self._wait_on_instance('VM running', timeout=self.timeout)
docs: Create new test instance in a resource group with the same name.