GoStart dt=3 g=57 g_seq=12
GoLabel dt=2 label_string=2
GoBlock dt=1049 reason_string=15 stack=5
GoUnblock dt=23 g=58 g_seq=7 stack=0
GoStart dt=8 g=58 g_seq=8
GoLabel dt=1 label_string=2
GoBlock dt=1126 reason_string=15 stack=5
GoUnblock dt=12 g=53 g_seq=3 stack=0
GoStart dt=5 g=53 g_seq=4
GoLabel dt=1 label_string=2
GoBlock dt=1751 reason_string=15 stack=5
GoUnblock dt=12 g=53 g_seq=5 stack=0
GoStart dt=6 g=53 g_seq=6
GoLabel dt=3 label_string=2

GoStart dt=118 g=22 g_seq=5
GoLabel dt=1 label_string=2
GoBlock dt=7117 reason_string=15 stack=27
ProcStop dt=41
ProcStart dt=150567 p=4 p_seq=7
GoUnblock dt=41 g=23 g_seq=4 stack=0
HeapAlloc dt=108 heapalloc_value=17163592
HeapAlloc dt=61 heapalloc_value=17166856
HeapAlloc dt=2994 heapalloc_value=17608712
GoStart dt=1008 g=23 g_seq=5
GoLabel dt=4 label_string=4

   *
   * @param <V> the type of the result
   */
  @FunctionalInterface
  public interface ClosingCallable<V extends @Nullable Object> {
    /**
     * Computes a result, or throws an exception if unable to do so.
     *
     * <p>Any objects that are passed to {@link DeferredCloser#eventuallyClose(Object, Executor)
     * closer.eventuallyClose()} will be closed when the {@link ClosingFuture} pipeline is done (but

		klog.ErrorS(err, "Unable to make pod data directories for pod", "pod", klog.KObj(pod))
		return false, err
	}

	// Wait for volumes to attach/mount
	if err := kl.volumeManager.WaitForAttachAndMount(ctx, pod); err != nil {
		if !wait.Interrupted(err) {
			kl.recorder.Eventf(pod, v1.EventTypeWarning, events.FailedMountVolume, "Unable to attach or mount volumes: %v", err)

		}

		relabelVolume := false
		// If the volume supports SELinux and it has not been
		// relabeled already and it is not a read-only volume,
		// relabel it and mark it as labeled
		if vol.Mounter.GetAttributes().Managed && vol.Mounter.GetAttributes().SELinuxRelabel && !vol.SELinuxLabeled {
			vol.SELinuxLabeled = true
			relabelVolume = true
		}

            string(static_cast<const char*>(tensor_interface->Data()),
                   tensor_interface->ByteSize()))) {
      return InvalidArgument(
          "Malformed TF_RESOURCE tensor: unable to parse resource handle");
    }
    return absl::OkStatus();
  }
  return absl::OkStatus();
}

static bool TF_Run_Inputs(TF_Tensor* const* c_inputs,

# Runs: kubectl label --overwrite nodes -l "${1}" "${2}"
# Retries on failure
#
# $1: label selector of nodes
# $2: label to apply
function update-node-label() {
  local selector="$1"
  local label="$2"
  local retries=5
  until (( retries == 0 )); do
    if kubectl label --overwrite nodes -l "${selector}" "${label}"; then
      break
    fi
    (( retries-- ))

		tc.Lock()
		defer tc.Unlock()

		metrics := &metricsapi.PodMetricsList{}
		for i, cpu := range tc.reportedLevels {
			// NB: the list reactor actually does label selector filtering for us,
			// so we have to make sure our results match the label selector
			podMetric := metricsapi.PodMetrics{
				ObjectMeta: metav1.ObjectMeta{
					Name:      fmt.Sprintf("%s-%d", podNamePrefix, i),
					Namespace: namespace,