public async Task UpsertAsync()

in Elastic.SemanticKernel.Connectors.Elasticsearch/ElasticsearchVectorStoreRecordCollection.cs [269:286]

• 13 lines of code
• 1 McCabe index (conditional complexity)

    public async Task<string> UpsertAsync(TRecord record, UpsertRecordOptions? options = null,
        CancellationToken cancellationToken = default)
    {
        // TODO: Handle options

        Verify.NotNull(record);

        var storageModel = VectorStoreErrorHandler.RunModelConversion(DatabaseName, CollectionName, "index",
            () => _mapper.MapFromDataToStorageModel(record));

        var id = await RunOperationAsync(
                "index",
                () => _elasticsearchClient.IndexDocumentAsync(CollectionName, storageModel.id!, storageModel.document,
                    cancellationToken))
            .ConfigureAwait(false);

        return id;
    }