diff --git a/flytekit/remote/remote.py b/flytekit/remote/remote.py index fabad06441..4ba7032437 100644 --- 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