(
self, context: PipelineContext, next_func: Callable[[], Awaitable[None]]
)
| 841 | """Handles post-processing and logging""" |
| 842 | |
| 843 | async def process( |
| 844 | self, context: PipelineContext, next_func: Callable[[], Awaitable[None]] |
| 845 | ) -> None: |
| 846 | post_processor = PostProcessingStage() |
| 847 | await post_processor.process_completions( |
| 848 | context.completions, context.websocket |
| 849 | ) |
| 850 | |
| 851 | await next_func() |
| 852 | |
| 853 | |
| 854 | @router.websocket("/generate-code") |
nothing calls this directly
no test coverage detected