fetch workflow id

Signed-off-by: Niels Bantilan <[email protected]>
flyteorg · Nov 3, 2021 · 46e4b5d · 46e4b5d
1 parent d8b660b
commit 46e4b5d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/flytekit/remote/remote.py b/flytekit/remote/remote.py
@@ -1031,7 +1031,8 @@ def sync_workflow_execution(
         if execution.spec.launch_plan.resource_type == ResourceType.TASK:
             flyte_entity = self.fetch_task(lp_id.project, lp_id.domain, lp_id.name, lp_id.version)
         else:
-            flyte_entity = self.fetch_launch_plan(lp_id.project, lp_id.domain, lp_id.name, lp_id.version)
+            wf_id = self.fetch_launch_plan(lp_id.project, lp_id.domain, lp_id.name, lp_id.version).workflow_id
+            flyte_entity = self.fetch_workflow(wf_id.project, wf_id.domain, wf_id.name, wf_id.version)
 
         # sync closure, node executions, and inputs/outputs
         execution._closure = self.client.get_execution(execution.id).closure