- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for original_nodes (0.17 sec)
-
tensorflow/compiler/mlir/tensorflow/translate/import_model.cc
return create_op_type_and_name_locations(); } const auto& node_def = node.def(); auto original_nodes = node_def.experimental_debug_info().original_node_names(); auto original_funcs = node_def.experimental_debug_info().original_func_names(); if (original_nodes.empty()) { return create_op_type_and_name_locations(); } else {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 01 11:17:36 UTC 2024 - 183.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
return true } originalNode, err := kl.GetNode() if err != nil { klog.ErrorS(err, "Error getting the current node from lister") return false } readyIdx, originalNodeReady := nodeutil.GetNodeCondition(&originalNode.Status, v1.NodeReady) if readyIdx == -1 { klog.ErrorS(nil, "Node does not have NodeReady condition", "originalNode", originalNode) return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
tensorflow/compiler/jit/encapsulate_util.cc
for (const Edge* e : control_edges) { g->AddControlEdge(original_node, e->dst()); g->RemoveEdge(e); } for (int i = 0, end = data_edges.size(); i < end; i++) { Node* dst = data_edges[i].dst; NodeDef new_def = dst->def(); int dst_input = data_edges[i].dst_input; *new_def.mutable_input(dst_input) = absl::StrCat(original_node->name(), ":", node_src_output);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Mar 12 06:33:33 UTC 2024 - 15.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin.go
} // framework.Delete: return Queue when node has topologyKey in its labels, else return QueueSkip. if !nodeLabelsMatchSpreadConstraints(originalNode.Labels, constraints) { logger.V(5).Info("the deleted node doesn't match pod topology spread constraints", "pod", klog.KObj(pod), "node", klog.KObj(originalNode)) return framework.QueueSkip, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go
originalNode, modifiedNode, err := util.As[*v1.Node](oldObj, newObj) if err != nil { return framework.Queue, err } wasUntolerated := true if originalNode != nil { _, wasUntolerated = v1helper.FindMatchingUntoleratedTaint(originalNode.Spec.Taints, pod.Spec.Tolerations, helper.DoNotScheduleTaintsFilterFunc()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/controller/util/node/controller_utils.go
if !ok { logger.Error(nil, "Received unexpected object", "object", originalObj) return } originalNode, ok = deletedState.Obj.(*v1.Node) if !ok { logger.Error(nil, "DeletedFinalStateUnknown contained non-Node object", "object", deletedState.Obj) return } } node := originalNode.DeepCopy() if err := f(node); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 10.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/groovy/scripts/internal/GradleResolveVisitor.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 67.6K bytes - Viewed (0) -
pkg/controller/testutil/test_utils.go
originalObjJS, err := json.Marshal(nodeCopy) if err != nil { klog.FromContext(ctx).Error(nil, "Failed to marshal", "node", klog.KObj(&nodeCopy)) return nil, nil } var originalNode v1.Node if err = json.Unmarshal(originalObjJS, &originalNode); err != nil { klog.FromContext(ctx).Error(err, "Failed to unmarshal original object") return nil, nil } var patchedObjJS []byte switch pt {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager_test.go
Kind: nodeKind.Kind, Name: "node1", }, }, } } func applyNodeStatusPatch(originalNode *v1.Node, patch []byte) (*v1.Node, error) { original, err := json.Marshal(originalNode) if err != nil { return nil, fmt.Errorf("failed to marshal original node %#v: %v", originalNode, err) } updated, err := strategicpatch.StrategicMergePatch(original, patch, v1.Node{}) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 17 02:02:59 UTC 2022 - 34.3K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
if kubeClient == nil { return fmt.Errorf("error getting kube client") } nodeClient := kubeClient.CoreV1().Nodes() originalNode, err := nodeClient.Get(context.TODO(), string(nim.nodeName), metav1.GetOptions{}) if err != nil { return err } node := originalNode.DeepCopy() needUpdate := false for _, update := range updateFuncs { newNode, updated, err := update(node) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0)