# Text form of tensorflow.tf2xla.Config proto.
feed {
  id { node_name: "p_hold" }
  shape {}
}
feed {
  id { node_name: "x_hold" }
  shape {
    dim { size: 1 }
  }
}
feed {
  id { node_name: "y_hold" }
  shape {
    dim { size: 1 }
  }
}
fetch {
  id { node_name: "result" }

  x = array_ops.placeholder(dtypes.int32, name='x_hold')
  y = array_ops.placeholder(dtypes.int32, name='y_hold')
  control_flow_assert.Assert(
      math_ops.equal(x, y), ['Expected x == y.'], name='assert_eq')
  math_ops.add(x, math_ops.negative(y), name='x_y_diff')


def tfcond(_):
  p = array_ops.placeholder(dtypes.bool, name='p_hold')
  x = array_ops.placeholder(dtypes.int32, name='x_hold')

# Text form of tensorflow.tf2xla.Config proto.
feed {
  id { node_name: "x_hold" }
  shape {
    dim { size: 2 }
    dim { size: 2 }
  }
  name: "x"
}
feed {
  id { node_name: "y_hold" }
  shape {
    dim { size: 2 }
    dim { size: 2 }
  }
  name: "y"
}
fetch {
  id { node_name: "x_y_prod" }
  name: "x_y_prod"
}
fetch {
  id { node_name: "x_y_sum" }
  name: "x_y_sum"

# Text form of tensorflow.tf2xla.Config proto.
feed {
  id { node_name: "x_hold" }
  shape {
    dim { size: 2 }
    dim { size: 3 }
  }
}
feed {
  id { node_name: "y_hold" }
  shape {
    dim { size: 3 }
    dim { size: 2 }
  }
}
fetch {
  id { node_name: "x_y_prod" }

# Text form of tensorflow.tf2xla.Config proto.
feed {
  id { node_name: "x_hold" }
  shape {
    dim { size: <M> }
    dim { size: <K> }
  }
}
feed {
  id { node_name: "y_hold" }
  shape {
    dim { size: <K> }
    dim { size: <N> }
  }
}
fetch {
  id { node_name: "x_y_prod" }

# Text form of tensorflow.tf2xla.Config proto.
feed {
  id { node_name: "x_hold" }
  shape {
    dim { size: 1 }
  }
}
feed {
  id { node_name: "y_hold" }
  shape {
    dim { size: 1 }
  }
}
fetch {
  id { node_name: "x_y_diff" }

func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) {
	if objInfo.DeleteMarker {
		return false
	}

	lhold := objectlock.GetObjectLegalHoldMeta(objInfo.UserDefined)
	if lhold.Status.Valid() && lhold.Status == objectlock.LegalHoldOn {
		return true
	}

	ret := objectlock.GetObjectRetentionMeta(objInfo.UserDefined)

		if !w.onHold {
			t.Errorf("Prober should be on hold due to %s check failure", probeType)
		}

		// Set a new container ID to lift the hold. The next probe will succeed.
		status.ContainerStatuses[0].ContainerID = "test://newCont_ID"
		m.statusManager.SetPodStatus(w.pod, status)
		msg = "hold lifted"
		expectContinue(t, w, w.doProbe(ctx), msg)
		expectResult(t, w, results.Success, msg)
		if w.onHold {

func ParseObjectLockLegalHoldHeaders(h http.Header) (lhold ObjectLegalHold, err error) {
	holdStatus, ok := h[AmzObjectLockLegalHold]
	if ok {
		lh := parseLegalHoldStatus(holdStatus[0])
		if !lh.Valid() {
			return lhold, ErrUnknownWORMModeDirective
		}
		lhold = ObjectLegalHold{XMLNS: "http://s3.amazonaws.com/doc/2006-03-01/", Status: lh}
	}
	return lhold, nil
}

// ObjectLegalHold specified in

		}
		w.containerID = kubecontainer.ParseContainerID(c.ContainerID)
		w.resultsManager.Set(w.containerID, w.initialValue, w.pod)
		// We've got a new container; resume probing.
		w.onHold = false
	}

	if w.onHold {
		// Worker is on hold until there is a new container.
		return true
	}

	if c.State.Running == nil {
		klog.V(3).InfoS("Non-running container probed",