If current pipeline support model reuse, common postprocess code should be write here. Args: inputs: input data post_params: post process parameters Return: dict of results: a dict containing outputs of model, each
(self, inputs: Dict[str, Any],
**post_params)
| 427 | return self.model(inputs, **forward_params) |
| 428 | |
| 429 | def postprocess(self, inputs: Dict[str, Any], |
| 430 | **post_params) -> Dict[str, Any]: |
| 431 | """ If current pipeline support model reuse, common postprocess |
| 432 | code should be write here. |
| 433 | |
| 434 | Args: |
| 435 | inputs: input data |
| 436 | post_params: post process parameters |
| 437 | |
| 438 | Return: |
| 439 | dict of results: a dict containing outputs of model, each |
| 440 | output should have the standard output name. |
| 441 | """ |
| 442 | raise NotImplementedError('postprocess') |
| 443 | |
| 444 | |
| 445 | class DistributedPipeline(Pipeline): |
no outgoing calls
no test coverage detected