tf_executor.yield
    }
    tf_executor.fetch %1 : !tf_executor.control
  }
  func.return
}

// CHECK: %[[REPLICA_0:.*]] = tf_executor.island
// CHECK: %[[REPLICA_1:.*]] = tf_executor.island
// CHECK: %[[SINK:.*]] = tf_executor.island(%[[REPLICA_0]], %[[REPLICA_1]])
// CHECK: tf_executor.fetch %[[SINK]]


// Tests unused replica are pinned to the graph fetch.
// CHECK-LABEL: func @unused_replica

      tf_executor.yield %arg0 : i32
    }
    %2:2 = tf_executor.island {
      tf_executor.yield %1#0 : i32
    }
    tf_executor.fetch %2#0 : i32
  }
  func.return %0 : i32
}

// Check that an unused island that doesn't contribute to the fetch is removed.
// CHECK-LABEL: func @dead_island(
func.func @dead_island(%arg0 : i32) -> i32 {
// CHECK: tf_executor.island
// CHECK-NOT: tf_executor.island

            }
        }
    }

    void maven(URI uri) {
        sections << new GenericSection({ """maven { url "$uri" }""" }, { """maven { setUrl("$uri") }""" })
    }

    void ivy(URI uri) {
        sections << new GenericSection({ """ivy { url "$uri" }""" }, { """ivy { setUrl("$uri") }""" })
    }

	})

	ExtraSimplePods.Set(nil)
	assert.EventuallyEqual(t, fetch, []SimpleEndpoint{
		{pod.Name, svc.Name, pod.Namespace, "1.2.3.4"},
	})

	pod.Status.PodIP = "1.2.3.5"
	pc.UpdateStatus(pod)
	assert.EventuallyEqual(t, fetch, []SimpleEndpoint{{pod.Name, svc.Name, pod.Namespace, "1.2.3.5"}})

	pc.Delete(pod.Name, pod.Namespace)
	assert.EventuallyEqual(t, fetch, nil)

	pod2 := &corev1.Pod{

// CHECK: functions must be of a single Graph with single op Islands: first op in function is not a tf_executor.graph

// -----

func.func @main() {
  tf_executor.graph {
    tf_executor.fetch
  }
  tf_executor.graph {
    tf_executor.fetch
  }
  func.return
}

// CHECK: functions must be of a single Graph with single op Islands: function does not only contain a single tf_executor.graph

// -----

func.func @main() {

# PRUNE-NEXT:      tf_executor.fetch %[[ASSIGN_ADD_CTRL]]

# Tests multiple target nodes with pruning set. Unreachable nodes from the
# fetch, including side effecting nodes, will be removed. The target nodes are
# added to the graph fetch as controls.
#
# PRESERVE-LABEL: func @main
# PRESERVE-SAME:  control_outputs = "Variable/Assign,AssignAdd"

    %control = tf_executor.ControlTrigger {}
    tf_executor.fetch
  }
  func.return
}

// -----

// CHECK-LABEL: func @empty_graph
// CHECK-NEXT: return
func.func @empty_graph() {
  tf_executor.graph {
    tf_executor.fetch
  }
  func.return
}

// CHECK-LABEL: func @empty_island
// CHECK-NEXT: return
func.func @empty_island() {

        profile.setId("pro");
        settings.addProfile(profile);
        Repository repo1 = new Repository();
        repo1.setUrl("http://apache.org/");
        repo1.setId("test");
        profile.addRepository(repo1);
        Repository repo2 = new Repository();
        repo2.setUrl("http://apache.org/");
        repo2.setId("test");
        profile.addRepository(repo2);

      tf_executor.yield %1#0, %1#1 : tensor<i32>, tensor<f32> loc("identity@some_function")
    } loc("identity@some_function")
    tf_executor.fetch
  }
  func.return
}

// CHECK-LABEL: func @island_no_wrap_print_mismatched_results
func.func @island_no_wrap_print_mismatched_results(%arg0: tensor<i32>, %arg1: tensor<f32>) {
  tf_executor.graph {

env GOPROXY=$proxy/sumdb-503
! go get rsc.io/quote
stderr 503

# fetch through working proxy is OK
cp go.mod.orig go.mod
rm go.sum
env GOPROXY=$proxy
go get rsc.io/quote

# repeated fetch works entirely from cache, does not consult sumdb
cp go.mod.orig go.mod
rm go.sum
env GOPROXY=$proxy/sumdb-503
go get rsc.io/quote
rm go.sum

# fetch specific module can work without proxy, using cache or go.sum