@@ -80,7 +80,7 @@ def _default_runnable_builder(
80
80
system_instruction : Optional [str ] = None ,
81
81
prompt : Optional ["QueryComponent" ] = None ,
82
82
retriever : Optional ["QueryComponent" ] = None ,
83
- summarizer : Optional ["QueryComponent" ] = None ,
83
+ response_synthesizer : Optional ["QueryComponent" ] = None ,
84
84
runnable_kwargs : Optional [Mapping [str , Any ]] = None ,
85
85
) -> "QueryPipeline" :
86
86
"""Creates a default runnable builder for LlamaIndex."""
@@ -101,17 +101,17 @@ def _default_runnable_builder(
101
101
}
102
102
if retriever :
103
103
pipeline_modules ["retriever" ] = retriever
104
- if summarizer :
105
- pipeline_modules ["summarizer " ] = summarizer
104
+ if response_synthesizer :
105
+ pipeline_modules ["response_synthesizer " ] = response_synthesizer
106
106
107
107
pipeline .add_modules (pipeline_modules )
108
108
pipeline .add_link ("prompt" , "model" )
109
109
if "retriever" in pipeline_modules :
110
110
pipeline .add_link ("model" , "retriever" )
111
- if "summarizer " in pipeline_modules :
112
- pipeline .add_link ("model" , "summarizer " , dest_key = "query_str" )
111
+ if "response_synthesizer " in pipeline_modules :
112
+ pipeline .add_link ("model" , "response_synthesizer " , dest_key = "query_str" )
113
113
if "retriever" in pipeline_modules :
114
- pipeline .add_link ("retriever" , "summarizer " , dest_key = "nodes" )
114
+ pipeline .add_link ("retriever" , "response_synthesizer " , dest_key = "nodes" )
115
115
116
116
return pipeline
117
117
@@ -199,8 +199,8 @@ def __init__(
199
199
model_builder : Optional [Callable [..., "FunctionCallingLLM" ]] = None ,
200
200
retriever_kwargs : Optional [Mapping [str , Any ]] = None ,
201
201
retriever_builder : Optional [Callable [..., "QueryComponent" ]] = None ,
202
- summarizer_kwargs : Optional [Mapping [str , Any ]] = None ,
203
- summarizer_builder : Optional [Callable [..., "QueryComponent" ]] = None ,
202
+ response_synthesizer_kwargs : Optional [Mapping [str , Any ]] = None ,
203
+ response_synthesizer_builder : Optional [Callable [..., "QueryComponent" ]] = None ,
204
204
runnable_kwargs : Optional [Mapping [str , Any ]] = None ,
205
205
runnable_builder : Optional [Callable [..., "QueryPipeline" ]] = None ,
206
206
enable_tracing : bool = False ,
@@ -217,7 +217,9 @@ def __init__(
217
217
prompt=prompt,
218
218
model=model,
219
219
retriever=retriever_builder(model, retriever_kwargs),
220
- summarizer=summarizer_builder(model, summarizer_kwargs),
220
+ response_synthesizer=response_synthesizer_builder(
221
+ model, response_synthesizer_kwargs
222
+ ),
221
223
runnable_kwargs=runnable_kwargs,
222
224
)
223
225
```
@@ -280,13 +282,15 @@ def __init__(
280
282
"prompt": prompt,
281
283
"model": model,
282
284
"retriever": retriever_builder(retriever_kwargs),
283
- "summarizer": summarizer_builder(summarizer_kwargs),
285
+ "response_synthesizer": response_synthesizer_builder(
286
+ response_synthesizer_kwargs
287
+ ),
284
288
},
285
289
)
286
290
pipeline.add_link("prompt", "model")
287
291
pipeline.add_link("model", "retriever")
288
- pipeline.add_link("model", "summarizer ", dest_key="query_str")
289
- pipeline.add_link("retriever", "summarizer ", dest_key="nodes")
292
+ pipeline.add_link("model", "response_synthesizer ", dest_key="query_str")
293
+ pipeline.add_link("retriever", "response_synthesizer ", dest_key="nodes")
290
294
```
291
295
292
296
Args:
@@ -329,10 +333,10 @@ def __init__(
329
333
Optional. Keyword arguments for the retriever constructor.
330
334
retriever_builder (Callable):
331
335
Optional. Callable that returns a retriever object.
332
- summarizer_kwargs (Mapping[str, Any]):
333
- Optional. Keyword arguments for the summarizer constructor.
334
- summarizer_builder (Callable):
335
- Optional. Callable that returns a summarizer object.
336
+ response_synthesizer_kwargs (Mapping[str, Any]):
337
+ Optional. Keyword arguments for the response synthesizer constructor.
338
+ response_synthesizer_builder (Callable):
339
+ Optional. Callable that returns a response_synthesizer object.
336
340
runnable_kwargs (Mapping[str, Any]):
337
341
Optional. Keyword arguments for the runnable constructor.
338
342
runnable_builder (Callable):
@@ -356,9 +360,9 @@ def __init__(
356
360
self ._retriever_kwargs = retriever_kwargs or {}
357
361
self ._retriever_builder = retriever_builder
358
362
359
- self ._summarizer = None
360
- self ._summarizer_kwargs = summarizer_kwargs or {}
361
- self ._summarizer_builder = summarizer_builder
363
+ self ._response_synthesizer = None
364
+ self ._response_synthesizer_kwargs = response_synthesizer_kwargs or {}
365
+ self ._response_synthesizer_builder = response_synthesizer_builder
362
366
363
367
self ._runnable = None
364
368
self ._runnable_kwargs = runnable_kwargs or {}
@@ -371,7 +375,7 @@ def set_up(self):
371
375
"""Sets up the agent for execution of queries at runtime.
372
376
373
377
It initializes the model, connects it with the prompt template,
374
- retriever and summarizer .
378
+ retriever and response_synthesizer .
375
379
376
380
This method should not be called for an object that being passed to
377
381
the ReasoningEngine service for deployment, as it initializes clients
@@ -478,10 +482,10 @@ def set_up(self):
478
482
retriever_kwargs = self ._retriever_kwargs ,
479
483
)
480
484
481
- if self ._summarizer_builder :
482
- self ._summarizer = self ._summarizer_builder (
485
+ if self ._response_synthesizer_builder :
486
+ self ._response_synthesizer = self ._response_synthesizer_builder (
483
487
model = self ._model ,
484
- summarizer_kwargs = self ._summarizer_kwargs ,
488
+ response_synthesizer_kwargs = self ._response_synthesizer_kwargs ,
485
489
)
486
490
487
491
runnable_builder = self ._runnable_builder or _default_runnable_builder
@@ -490,7 +494,7 @@ def set_up(self):
490
494
model = self ._model ,
491
495
system_instruction = self ._system_instruction ,
492
496
retriever = self ._retriever ,
493
- summarizer = self ._summarizer ,
497
+ response_synthesizer = self ._response_synthesizer ,
494
498
runnable_kwargs = self ._runnable_kwargs ,
495
499
)
496
500
@@ -506,8 +510,10 @@ def clone(self) -> "LlamaIndexQueryPipelineAgent":
506
510
model_builder = self ._model_builder ,
507
511
retriever_kwargs = copy .deepcopy (self ._retriever_kwargs ),
508
512
retriever_builder = self ._retriever_builder ,
509
- summarizer_kwargs = copy .deepcopy (self ._summarizer_kwargs ),
510
- summarizer_builder = self ._summarizer_builder ,
513
+ response_synthesizer_kwargs = copy .deepcopy (
514
+ self ._response_synthesizer_kwargs
515
+ ),
516
+ response_synthesizer_builder = self ._response_synthesizer_builder ,
511
517
runnable_kwargs = copy .deepcopy (self ._runnable_kwargs ),
512
518
runnable_builder = self ._runnable_builder ,
513
519
enable_tracing = self ._enable_tracing ,
0 commit comments