Adds generic flow to declarative orchestrator

PrefectHQ · Dec 11, 2023 · 5c36359 · 5c36359
1 parent 2b9f07f
commit 5c36359
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/flows-advanced/declarative-graph-orchestrator/orchestration.py b/flows-advanced/declarative-graph-orchestrator/orchestration.py
@@ -85,9 +85,17 @@ async def worker_task(name: str):
             wait_for=upstream_deployment_futures,
         )
 
+
 @flow(name="orchestration-test-flow")
 async def example_flow():
     await run_orchestrator_flow(DeploymentFilterTags(all_=["group:ml"]))
 
+
+@flow
+async def orchestrator_flow(tags: List[str]):
+    """Generic entrypoint flow for the orchestrator for remote reference"""
+    await run_orchestrator_flow(DeploymentFilterTags(all_=tags))
+
+
 if __name__ == "__main__":
     asyncio.run(example_flow())