auto func_ty = func_op.getFunctionType();
      BuildBodyWithCall(rewriter, loc, func, func_ty, region);
    };

    // Insert a call to the select function in the select region of the mhlo op.
    insert_call_to(op.getSelect(), &select_and_scatter_op.getSelect());
    // Insert a call to the scatter function in the scatter region of the mhlo
    // op.
    insert_call_to(op.getScatter(), &select_and_scatter_op.getScatter());

	}

	// Add use_downstream_protocol for sidecar proxy only if protocol sniffing is enabled. Since
	// protocol detection is disabled for gateway and use_downstream_protocol is used under protocol
	// detection for cluster to select upstream connection protocol when the service port is unnamed.
	// use_downstream_protocol should be disabled for gateway; while it sort of makes sense there, even

    }
    if (auto xla_select_and_scatter_op =
            dyn_cast<TF::XlaSelectAndScatterOp>(op)) {
      return propagate_shape_to(xla_select_and_scatter_op.getSelect())
                 .value() &&
             propagate_shape_to(xla_select_and_scatter_op.getScatter()).value();
    } else if (auto xla_variadic_reduce_v2_op =

                    details == 'Trying to write an output to a read-only location which is for Gradle internal use only'
                    solutions == ['Select a different output location']
                    additionalData.asMap == [
                        'typeName': 'org.gradle.api.DefaultTask',
                        'propertyName': 'output',
                    ]

const NamespaceNameLabel = "kubernetes.io/metadata.name"

// toNamespaceSet converts a set of namespace labels to a Set that can be used to select against.
func toNamespaceSet(name string, labels map[string]string) klabels.Set {
	// If namespace label is not set, implicitly insert it to support older Kubernetes versions
	if labels[NamespaceNameLabel] == name {

			}
			if ok {
				continue
			}
		} // in all other cases metadata is corrupt, do not read from it.

		onlineMeta[i] = FileInfo{}
		onlineDisks[i] = nil
	}

	select {
	case mrfCheck <- fi.ShallowCopy():
	case <-ctx.Done():
		return fi, onlineMeta, onlineDisks, toObjectErr(ctx.Err(), bucket, object)
	}

	return fi, onlineMeta, onlineDisks, nil
}

			// and that muddles the debugging experience.
			if b.Pos == src.NoXPos {
				b.Pos = bCond.Pos
			}
		}

		s.startBlock(bEnd)

	case ir.OSWITCH, ir.OSELECT:
		// These have been mostly rewritten by the front end into their Nbody fields.
		// Our main task is to correctly hook up any break statements.
		bEnd := s.f.NewBlock(ssa.BlockPlain)

		prevBreak := s.breakTo