(self, node_params, flow_params)
| 312 | self.extra = {} |
| 313 | |
| 314 | def valid_args(self, node_params, flow_params): |
| 315 | flow_params_serializer_class = self.get_flow_params_serializer_class() |
| 316 | node_params_serializer_class = self.get_node_params_serializer_class() |
| 317 | if flow_params_serializer_class is not None and flow_params is not None: |
| 318 | self.flow_params_serializer = flow_params_serializer_class(data=flow_params) |
| 319 | self.flow_params_serializer.is_valid(raise_exception=True) |
| 320 | if node_params_serializer_class is not None: |
| 321 | self.node_params_serializer = node_params_serializer_class(data=node_params) |
| 322 | self.node_params_serializer.is_valid(raise_exception=True) |
| 323 | if self.node.properties.get('status', 200) != 200: |
| 324 | raise ValidationError(ErrorDetail(f'节点{self.node.properties.get("stepName")} 不可用')) |
| 325 | |
| 326 | def get_reference_field(self, fields: List[str]): |
| 327 | return self.get_field(self.context, fields) |
no test coverage detected