async def arun_multi_with_intermediates(
        self,
        module_input_dict: Dict[str, Any],
        callback_manager: Optional[CallbackManager] = None,
    ) -> Dict[str, Any]:
        """Run the pipeline for multiple roots."""
        callback_manager = callback_manager or self.callback_manager
        self.set_callback_manager(callback_manager)
        with self.callback_manager.as_trace("query"):
            with self.callback_manager.event(
                CBEventType.QUERY,
                payload={EventPayload.QUERY_STR: json.dumps(module_input_dict)},
            ) as query_event:
                outputs, _ = await self._arun_multi(
                    module_input_dict, show_intermediates=True
                )
                return outputs
Run the pipeline for multiple roots.
llama-index-core/llama_index/core/query_pipeline/query.py