}

    def "can register progress loggers for different test workers"() {
        def testWorkerProgressLogger1 = Mock(ProgressLogger)
        def testWorkerProgressLogger2 = Mock(ProgressLogger)

        given:
        def testEvent1 = new TestEvent('Gradle Test Executor 1', 'org.gradle.Test1')
        def testEvent2 = new TestEvent('Gradle Test Executor 2', 'org.gradle.Test2')
        def testDescriptor1 = createTestDescriptor(testEvent1)

apiVersion: kubeadm.k8s.io/v1beta3
kind: ClusterConfiguration

}
type J interface {
	M()
}

type T struct{}

func (*T) M() {}

func main() {
	test1()
	test2()
}

func test1() {
	t := new(T)
	var i1, i2 I
	var j interface {
		M()
	}
	i1 = t
	j = t
	i2 = j
	if i1 != i2 {
		panic("interfaces not equal")
	}
}

func test2() {
	t := new(T)
	i1 := (I)(t)
	i2 := (I)((interface {
		M()
	})((J)(t)))
	if i1 != i2 {

def test_multiple_path():
    app = FastAPI()

    @app.get("/test1")
    @app.get("/test2")
    async def test(var: Annotated[str, Query()] = "bar"):
        return {"foo": var}

    client = TestClient(app)
    response = client.get("/test1")
    assert response.status_code == 200
    assert response.json() == {"foo": "bar"}

    response = client.get("/test1", params={"var": "baz"})
    assert response.status_code == 200

					},
				},
			},
		},
	}

	expectedns := []string{
		"testns/super-high-priority", "testns/high-priority", "testns/default-priority", "testns/a-medium-priority",
		"testns/b-medium-priority", "testns/b-low-priority", "testns/a-low-priority",
	}

	expectedns1 := []string{"testns-1/default-priority", "testns-1/a-medium-priority", "testns-1/b-medium-priority"}

	for _, cfg := range envoyFilters {

    def "fires event on test class failure when some tests have been started"() {
        def failure = TestFailure.fromTestFrameworkFailure(new RuntimeException())
        TestDescriptorInternal test1 = Mock()
        TestDescriptorInternal test2 = Mock()

        given:
        idGenerator.generateId() >> 1
        test1.id >> 2
        test2.id >> 3

        and:
        processor.testClassStarted("some-test")

			configData: `---
kind: CredentialProviderConfig
apiVersion: kubelet.config.k8s.io/v1alpha1
providers:
  - name: test1
    matchImages:
    - "registry.io/one"
    defaultCacheDuration: 10m
    apiVersion: credentialprovider.kubelet.k8s.io/v1alpha1
  - name: test2
    matchImages:
    - "registry.io/two"
    defaultCacheDuration: 10m
    apiVersion: credentialprovider.kubelet.k8s.io/v1alpha1

	}

	// initiate a sync with all pods remaining
	state := podWorkers.SyncKnownPods([]*v1.Pod{
		newNamedPod("1-normal", "test1", "pod1", false),
		newNamedPod("2-static", "test1", "pod1", true),
		newNamedPod("3-static", "test1", "pod1", true),
		newNamedPod("4-static", "test1", "pod1", true),
	})
	drainAllWorkers(podWorkers)

	// 2-static and 3-static should both be listed as terminated

	"testing"

	"golang.org/x/mod/module"
)

func TestIsToolchain(t *testing.T) { test1(t, isToolchainTests, "IsToolchain", IsToolchain) }

var isToolchainTests = []testCase1[string, bool]{
	{"go", true},
	{"toolchain", true},
	{"anything", false},
	{"golang.org/toolchain", false},
}

func TestModCompare(t *testing.T) { test3(t, modCompareTests, "ModCompare", ModCompare) }

    public void run(RunNotifier runNotifier) {
        // Run tests in 'parallel'
        Description test1 = Description.createTestDescription(type, 'broken')
        Description test2 = Description.createTestDescription(type, 'ok')
        runNotifier.fireTestStarted(test1)
        runNotifier.fireTestStarted(test2)
        runNotifier.fireTestFailure(new Failure(test1, failure.rawFailure))
        runNotifier.fireTestFinished(test2)