From 07a45432a1cd839f289fd15012806f610cfe5c38 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Fabio=20Gr=C3=A4tz?= Date: Sat, 8 Mar 2025 11:44:51 +0100 Subject: [PATCH 1/2] Doc: Provide example of launchplan chaining MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Fabio Grätz --- .../advanced_composition/chain_entities.py | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/examples/advanced_composition/advanced_composition/chain_entities.py b/examples/advanced_composition/advanced_composition/chain_entities.py index 95a0ead83..a373ae4d5 100644 --- a/examples/advanced_composition/advanced_composition/chain_entities.py +++ b/examples/advanced_composition/advanced_composition/chain_entities.py @@ -1,4 +1,4 @@ -from flytekit import task, workflow +from flytekit import task, workflow, LaunchPlan @task @@ -47,3 +47,12 @@ def chain_workflows_wf(): sub_wf0 = sub_workflow_0() sub_wf0 >> sub_wf1 + +# Chaining launchplans + +@workflow +def chain_launchplans_wf(): + lp1 = LaunchPlan.get_or_create(sub_workflow_1, "lp1")() + lp0 = LaunchPlan.get_or_create(sub_workflow_0, "lp0")() + + lp0 >> lp1 From a56d4a5e05b8cfaefce1796a7e4e7d0ac86abf1d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Fabio=20Gr=C3=A4tz?= Date: Thu, 20 Mar 2025 22:33:14 +0100 Subject: [PATCH 2/2] lint MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Fabio Grätz --- .../advanced_composition/chain_entities.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/examples/advanced_composition/advanced_composition/chain_entities.py b/examples/advanced_composition/advanced_composition/chain_entities.py index a373ae4d5..d1b172974 100644 --- a/examples/advanced_composition/advanced_composition/chain_entities.py +++ b/examples/advanced_composition/advanced_composition/chain_entities.py @@ -1,4 +1,4 @@ -from flytekit import task, workflow, LaunchPlan +from flytekit import LaunchPlan, task, workflow @task @@ -48,8 +48,10 @@ def chain_workflows_wf(): sub_wf0 >> sub_wf1 + # Chaining launchplans + @workflow def chain_launchplans_wf(): lp1 = LaunchPlan.get_or_create(sub_workflow_1, "lp1")()