Skip to content

Commit

Permalink
feat: support batch upsert
Browse files Browse the repository at this point in the history
  • Loading branch information
chuang8511 committed Dec 9, 2024
1 parent d9015c4 commit e62fb7c
Showing 1 changed file with 0 additions and 27 deletions.
27 changes: 0 additions & 27 deletions pkg/component/data/pinecone/v0/task_upsert.go
Original file line number Diff line number Diff line change
Expand Up @@ -57,30 +57,3 @@ func convertOutput(resp upsertResp) *taskUpsertOutput {
upsertedCount: resp.RecordsUpserted,
}
}

// case taskUpsert:
// req := newIndexClient(e.Setup, e.GetLogger()).R()

// v := upsertInput{}
// err := base.ConvertFromStructpb(input, &v)
// if err != nil {
// job.Error.Error(ctx, err)
// continue
// }

// resp := upsertResp{}
// req.SetResult(&resp).SetBody(upsertReq{
// Vectors: []vector{v.vector},
// Namespace: v.Namespace,
// })

// if _, err := req.Post(upsertPath); err != nil {
// job.Error.Error(ctx, httpclient.WrapURLError(err))
// continue
// }

// output, err = base.ConvertToStructpb(upsertOutput(resp))
// if err != nil {
// job.Error.Error(ctx, err)
// continue
// }

0 comments on commit e62fb7c

Please sign in to comment.