feat(proto): add details to error status

jina-ai · Jun 15, 2020 · 0c0c8fe · 0c0c8fe
1 parent 941aa77
commit 0c0c8fe
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/jina/peapods/pea.py b/jina/peapods/pea.py
@@ -158,8 +158,7 @@ def handle(self, msg: 'jina_pb2.Message') -> 'BasePea':
 
         :param msg: the message received
         """
-        if msg.envelope.status.code < jina_pb2.Status.ERROR:
-            self.executor(self.request_type)
+        self.executor(self.request_type)
         return self
 
     @property

diff --git a/tests/test_flow.py b/tests/test_flow.py
@@ -310,6 +310,10 @@ def craft(self, *args, **kwargs):
         f = (Flow().add(name='r1', yaml_path='_forward')
              .add(name='r2', yaml_path='!DummyCrafter')
              .add(name='r3', yaml_path='!BaseEncoder'))
+
+        with f:
+            f.dry_run()
+
         with f:
             f.index_lines(lines=['abbcs', 'efgh'], output_fn=validate)