private final Client client;
    private final SuggestSettings settings;
    private final SuggestWriter suggestWriter;

    /**
     * Constructor.
     *
     * @param client The OpenSearch client
     * @param settings The suggest settings
     * @param suggestWriter The suggest writer for performing deletions
     */

        "type": "object",
    }


@pytest.mark.parametrize(
    "path",
    ["/required-str", "/model-required-str"],
)
def test_required_str_missing(path: str):
    client = TestClient(app)
    response = client.post(path)
    assert response.status_code == 422
    assert response.json() == {
        "detail": [
            {
                "type": "missing",
                "loc": ["body", "p"],

    /**
     * Constructor.
     * @param client OpenSearch client
     * @param settings Suggest settings
     */
    public AnalyzerConverter(final Client client, final SuggestSettings settings) {
        this.client = client;
        this.settings = settings;
        analyzerSettings = settings.analyzer();
    }

    @Override
    public void init() throws IOException {
        // nothing
    }

    @Override

            }
        ]
    )


@pytest.mark.parametrize(
    "path",
    ["/required-list-str", "/model-required-list-str"],
)
def test_required_list_str_missing(path: str):
    client = TestClient(app)
    response = client.get(path)
    assert response.status_code == 422
    assert response.json() == {
        "detail": [
            {
                "type": "missing",
                "loc": ["header", "p"],

    private final Client client;
    private final SuggestSettings settings;
    private final SuggestWriter suggestWriter;

    /**
     * Constructor.
     *
     * @param client The OpenSearch client
     * @param settings The suggest settings
     * @param suggestWriter The suggest writer for performing writes
     */

     * @param settings Suggest settings
     * @param client OpenSearch client
     * @param settingsIndexName Settings index name
     * @param settingsId Settings ID
     */
    protected ArraySettings(final SuggestSettings settings, final Client client, final String settingsIndexName, final String settingsId) {
        this.settings = settings;
        this.client = client;

@pytest.fixture(
    name="client",
    params=[
        pytest.param("tutorial005_py310", marks=needs_py310),
    ],
)
def get_client(request: pytest.FixtureRequest):
    mod = importlib.import_module(f"docs_src.body_nested_models.{request.param}")

    client = TestClient(mod.app)
    return client


def test_put_all(client: TestClient):
    response = client.put(
        "/items/123",
        json={

### Client Binaries

filename | sha512 hash
-------- | -----------
[kubernetes-client-darwin-amd64.tar.gz](https://dl.k8s.io/v1.34.6/kubernetes-client-darwin-amd64.tar.gz) | 695ba299dd0c9f845fb705ca05320e89074278e9b1c483f3d4c0f458de4f5bbbca3acf60f3f1a565c16765dac3e4859a2ba21dc367a119d7705f22380a76885a

        // Create a test witness client that uses our mock RPC client
        TestWitnessClient client = new TestWitnessClient(witnessServer, mockContext, mockRpc);

        TestNotificationListener listener = new TestNotificationListener();

        CompletableFuture<WitnessRegistration> future = client.registerForNotifications("\\\\server\\share", serverAddress, listener);

import org.opensearch.common.xcontent.XContentType;
import org.opensearch.index.query.QueryBuilders;
import org.opensearch.transport.client.Client;

/**
 * Integration tests for ScrollOperationHelper.
 */
public class ScrollOperationHelperTest {

    private static OpenSearchRunner runner;
    private static Client client;
    private static final String INDEX_NAME = "scroll-test-index";
    private Suggester suggester;

    @BeforeClass