|
|
|
@ -46,9 +46,10 @@ func BuildKnowledgeIndexing(ctx context.Context) (r compose.Runnable[document.So
|
|
|
|
}
|
|
|
|
}
|
|
|
|
_ = g.AddIndexerNode(RedisIndexer, redisIndexerKeyOfIndexer)
|
|
|
|
_ = g.AddIndexerNode(RedisIndexer, redisIndexerKeyOfIndexer)
|
|
|
|
_ = g.AddEdge(compose.START, FileLoader)
|
|
|
|
_ = g.AddEdge(compose.START, FileLoader)
|
|
|
|
_ = g.AddEdge(RedisIndexer, compose.END)
|
|
|
|
|
|
|
|
_ = g.AddEdge(FileLoader, MarkdownSplitter)
|
|
|
|
_ = g.AddEdge(FileLoader, MarkdownSplitter)
|
|
|
|
_ = g.AddEdge(MarkdownSplitter, RedisIndexer)
|
|
|
|
_ = g.AddEdge(MarkdownSplitter, RedisIndexer)
|
|
|
|
|
|
|
|
_ = g.AddEdge(RedisIndexer, compose.END)
|
|
|
|
|
|
|
|
|
|
|
|
r, err = g.Compile(ctx, compose.WithGraphName("KnowledgeIndexing"), compose.WithNodeTriggerMode(compose.AnyPredecessor))
|
|
|
|
r, err = g.Compile(ctx, compose.WithGraphName("KnowledgeIndexing"), compose.WithNodeTriggerMode(compose.AnyPredecessor))
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
return nil, err
|
|
|
|
|