diff --git a/flow/retriever/router/router.go b/flow/retriever/router/router.go index f0363388e..da96cd2d0 100644 --- a/flow/retriever/router/router.go +++ b/flow/retriever/router/router.go @@ -97,7 +97,7 @@ func NewRetriever(ctx context.Context, config *Config) (retriever.Retriever, err return &routerRetriever{ retrievers: config.Retrievers, - router: config.Router, + router: router, fusionFunc: fusion, }, nil }