docs: fix topology documentation (#6134)

jina-ai · Jan 8, 2024 · be263b1 · be263b1
1 parent 15a7b80
commit be263b1
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/docs/concepts/orchestration/flow.md b/docs/concepts/orchestration/flow.md
@@ -522,12 +522,18 @@ class BazExecutor(Executor):
         docs.append(TextDoc(text=f'baz was here and got {len(docs)} document'))
 
 
+class MergeExecutor(Executor):
+    @requests
+    async def merge(self, docs: DocList[TextDoc], **kwargs) -> DocList[TextDoc]:
+        return docs
+
+
 f = (
     Flow()
     .add(uses=FooExecutor, name='fooExecutor')
     .add(uses=BarExecutor, name='barExecutor', needs='fooExecutor')
     .add(uses=BazExecutor, name='bazExecutor', needs='fooExecutor')
-    .add(needs=['barExecutor', 'bazExecutor'])
+    .add(uses=MergeExecutor, needs=['barExecutor', 'bazExecutor'])
 )
 ```