To be overriden by the descendant class
(self, input:Dict[str,str], spatial_info:Dict[str,Any], temporal_info:Dict[str,Any],**kwargs)
| 539 | return results |
| 540 | |
| 541 | def _execute(self, input:Dict[str,str], spatial_info:Dict[str,Any], temporal_info:Dict[str,Any],**kwargs): |
| 542 | """ To be overriden by the descendant class """ |
| 543 | """ Use the processed input to get the result """ |
| 544 | |
| 545 | inputs = asyncio.run( |
| 546 | self._process_inputs( |
| 547 | input, |
| 548 | spatial_info, |
| 549 | temporal_info, |
| 550 | mode="default", |
| 551 | **kwargs, |
| 552 | ) |
| 553 | ) |
| 554 | message = [{'role':'system','content':inputs["system_prompt"]},{'role':'user','content':inputs["user_prompt"]}] |
| 555 | response = self.llm.gen(message) |
| 556 | return response |
| 557 | |
| 558 | async def _async_execute(self, input:Dict[str,str], spatial_info:Dict[str,Any], temporal_info:Dict[str,Any], mode: str = "default", **kwargs): |
| 559 | """Handle asynchronous execution across different KV cache strategies.""" |
nothing calls this directly
no test coverage detected