diff --git a/flows-advanced/declarative-graph-orchestrator/orchestration.py b/flows-advanced/declarative-graph-orchestrator/orchestration.py index f7ed0e22..20a7c330 100644 --- 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())