Skip to content

Commit e55e68d

Browse files
authored
Merge branch 'master' into feat-gcp-api
2 parents b178d75 + ec8c614 commit e55e68d

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

docs/concepts/orchestration/flow.md

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -522,12 +522,18 @@ class BazExecutor(Executor):
522522
docs.append(TextDoc(text=f'baz was here and got {len(docs)} document'))
523523
524524
525+
class MergeExecutor(Executor):
526+
@requests
527+
async def merge(self, docs: DocList[TextDoc], **kwargs) -> DocList[TextDoc]:
528+
return docs
529+
530+
525531
f = (
526532
Flow()
527533
.add(uses=FooExecutor, name='fooExecutor')
528534
.add(uses=BarExecutor, name='barExecutor', needs='fooExecutor')
529535
.add(uses=BazExecutor, name='bazExecutor', needs='fooExecutor')
530-
.add(needs=['barExecutor', 'bazExecutor'])
536+
.add(uses=MergeExecutor, needs=['barExecutor', 'bazExecutor'])
531537
)
532538
```
533539

docs/requirements.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ sphinxcontrib-redirects==0.1.0
66
sphinx-autodoc-typehints==1.18.3
77
sphinx_copybutton
88
sphinx-notfound-page==0.7.1
9-
gitpython==3.1.37
9+
gitpython==3.1.41
1010
sphinx-sitemap==2.5.0
1111
sphinxext-opengraph
1212
furo

0 commit comments

Comments
 (0)