Synchronous execution wrapper that normalizes outputs to a list.
(self, input:Any, **kwargs)
| 152 | return temporal_info |
| 153 | |
| 154 | def execute(self, input:Any, **kwargs): |
| 155 | """Synchronous execution wrapper that normalizes outputs to a list.""" |
| 156 | self.outputs = [] |
| 157 | spatial_info:Dict[str,Dict] = self.get_spatial_info() |
| 158 | temporal_info:Dict[str,Dict] = self.get_temporal_info() |
| 159 | results = [self._execute(input, spatial_info, temporal_info, **kwargs)] |
| 160 | |
| 161 | for result in results: |
| 162 | if not isinstance(result, list): |
| 163 | result = [result] |
| 164 | self.outputs.extend(result) |
| 165 | return self.outputs |
| 166 | |
| 167 | async def async_execute(self, input:Any, mode: str = "default", **kwargs): |
| 168 | """Execute a node asynchronously with optional KV cache handling modes.""" |
no test coverage detected