Run a parallel pipeline benchmark.
(self)
| 235 | |
| 236 | @abstractmethod |
| 237 | async def run_parallel_pipeline(self) -> BenchmarkMetrics: |
| 238 | """Run a parallel pipeline benchmark.""" |
| 239 | pass |
| 240 | |
| 241 | @abstractmethod |
| 242 | async def run_complex_workflow(self) -> BenchmarkMetrics: |
no outgoing calls