chore: make message more explicit to see error (#6053)

Signed-off-by: Joan Fontanals Martinez <[email protected]>
jina-ai · Sep 21, 2023 · 7d7918d · 7d7918d
1 parent 3652cfd
commit 7d7918d
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/jina/serve/runtimes/gateway/graph/topology_graph.py b/jina/serve/runtimes/gateway/graph/topology_graph.py
@@ -80,7 +80,7 @@ def _validate_against_outgoing_nodes(self):
                 if node._pydantic_models_by_endpoint is not None:  # gateway end
 
                     for endp in self._pydantic_models_by_endpoint.keys():
-                        outgoing_enp = endp
+                        outgoing_endp = endp
                         incoming_endp = (
                             endp
                             if endp in node._pydantic_models_by_endpoint
@@ -91,22 +91,22 @@ def _validate_against_outgoing_nodes(self):
 
                             if endp in node._pydantic_models_by_endpoint:
                                 if (
-                                    self._pydantic_models_by_endpoint[outgoing_enp][
+                                    self._pydantic_models_by_endpoint[outgoing_endp][
                                         'output'
                                     ].schema()
                                     != node._pydantic_models_by_endpoint[incoming_endp][
                                         'input'
                                     ].schema()
                                 ):
                                     raise Exception(
-                                        f'The output schema of {self.name} is incompatible with the input schema of {node.name}'
+                                        f'The output schema of {self.name} at {outgoing_endp} endpoint is incompatible with the input schema of {node.name} at {incoming_endp} endpoint'
                                     )
                         else:
                             if (
-                                outgoing_enp != __default_endpoint__
+                                outgoing_endp != __default_endpoint__
                             ):  # It could happen that there is an Encoder with default followed by an indexer with [index, search]
                                 raise Exception(
-                                    f'{node.name} does not expose {incoming_endp} which makes it impossible to be chained with {self.name} on {outgoing_enp}'
+                                    f'{node.name} does not expose {incoming_endp} which makes it impossible to be chained with {self.name} on {outgoing_endp}'
                                 )
                             else:
                                 self.logger.warning(