mlir::tf_device::ClusterFuncOp cluster_func_op = cluster_func_ops.front();

  tensorflow::tpu::TPUCompileMetadataProto compile_metadata;

  ASSERT_TRUE(mlir::succeeded(SetMetadataProtoFromClusterFuncOp(
      cluster_func_op,
      /*num_replicas=*/1, /*num_cores_per_replica=*/1, {}, &compile_metadata)));

  tensorflow::tpu::TPUCompileMetadataProto expected_compile_metadata;

		var dnsErr *DNSError
		if errors.As(err, &dnsErr) {
			succeeded := true
			if !dnsErr.IsNotFound {
				succeeded = false
				t.Logf("%v: IsNotFound is set to false", prefix)
			}

			if dnsErr.Err != errNoSuchHost.Error() {
				succeeded = false
				t.Logf("%v: error message is not equal to: %v", prefix, errNoSuchHost.Error())
			}

			if succeeded {
				return
			}
		}

/**
 * Allows an execution action to provide status information to the execution context.
 *
 * <p>Note: if the action does not call {@link #onFailure(Throwable)}, then the execution is assumed to have
 * succeeded.</p>
 */
public interface ExecutionListener {
    /**
     * Reports a failure of the execution. Note that it is the caller's responsibility to perform any logging of the
     * failure.
     *

	if err != nil {
		span.AddEvent("Txn call failed", attribute.String("err", err.Error()))
		return err
	}
	span.AddEvent("Txn call succeeded")

	if !txnResp.Succeeded {
		return storage.NewKeyExistsError(preparedKey, 0)
	}

	if out != nil {
		putResp := txnResp.Responses[0].GetResponsePut()
		err = decode(s.codec, s.versioner, data, out, putResp.Header.Revision)
		if err != nil {

		write("b", i, `package p
var
var
var
var
var
`)
	}

	cmd := exec.Command(args[0], args[1:]...)
	output, err := cmd.CombinedOutput()
	if err == nil {
		panic("compile succeeded unexpectedly")
	}
	if !bytes.Contains(output, []byte("syntax error:")) {
		panic(fmt.Sprintf(`missing "syntax error" in compiler output; got: 
%s`, output))
	}

        def succeededEvent = Mock(InternalOperationFinishedProgressEvent)
        _ * succeededEvent.getEventTime() >> 999
        _ * succeededEvent.getDisplayName() >> 'Test Work succeeded'
        _ * succeededEvent.getDescriptor() >> workItemDescriptor
        _ * succeededEvent.getResult() >> workItemResult

        adapter.onEvent(startEvent) // succeededEvent always assumes a previous startEvent

		log.Fatal(err)
	}

	cmd := exec.Command("go", "tool", "compile", "-p=p", "x.go")
	cmd.Dir = dir
	output, err := cmd.CombinedOutput()
	if err == nil {
		log.Fatal("compile succeeded unexpectedly")
	}
	if !bytes.Contains(output, []byte("only allowed in runtime")) {
		log.Fatalf("wrong error message from compiler; got:\n%s\n", output)
	}

 * interface from org.testng.internal to org.testng.
 *
 * @see TestNGListenerAdapterFactory
 */
public interface TestNGConfigurationListener {
    /**
     * Invoked whenever a configuration method succeeded.
     */
    void onConfigurationSuccess(ITestResult itr);

    /**
     * Invoked whenever a configuration method failed.
     */
    void onConfigurationFailure(ITestResult itr);

    /**

	out.StartTime = (*metav1.Time)(unsafe.Pointer(in.StartTime))
	out.CompletionTime = (*metav1.Time)(unsafe.Pointer(in.CompletionTime))
	out.Active = in.Active
	out.Succeeded = in.Succeeded
	out.Failed = in.Failed
	out.Terminating = (*int32)(unsafe.Pointer(in.Terminating))
	out.CompletedIndexes = in.CompletedIndexes
	out.FailedIndexes = (*string)(unsafe.Pointer(in.FailedIndexes))

        _ * testResult.getEndTime() >> 2

        def succeededEvent = Mock(InternalTestFinishedProgressEvent)
        _ * succeededEvent.getEventTime() >> 999
        _ * succeededEvent.getDisplayName() >> 'test suite succeeded'
        _ * succeededEvent.getDescriptor() >> testDescriptor
        _ * succeededEvent.getResult() >> testResult

        adapter.onEvent(startEvent) // succeededEvent always assumes a previous startEvent