diff --git a/go/helpers.go b/go/helpers.go index 32f1a57..90208b5 100644 --- a/go/helpers.go +++ b/go/helpers.go @@ -5,7 +5,6 @@ import ( "sync" "dappco.re/go" - corelog "dappco.re/go/log" ) const maxConcurrentEmbeddings = 8 @@ -89,7 +88,7 @@ func QueryDocs(ctx context.Context, question, collectionName string, topK int) c } defer func() { if r := qdrantClient.Close(); !r.OK { - corelog.Warn("qdrant close failed", "err", r.Error()) + core.Warn("qdrant close failed", "err", r.Error()) } }() @@ -121,7 +120,7 @@ func IngestDirectory(ctx context.Context, directory, collectionName string, recr } defer func() { if r := qdrantClient.Close(); !r.OK { - corelog.Warn("qdrant close failed", "err", r.Error()) + core.Warn("qdrant close failed", "err", r.Error()) } }() @@ -150,7 +149,7 @@ func IngestSingleFile(ctx context.Context, filePath, collectionName string) core } defer func() { if r := qdrantClient.Close(); !r.OK { - corelog.Warn("qdrant close failed", "err", r.Error()) + core.Warn("qdrant close failed", "err", r.Error()) } }()