Sharon Gong
04/14/2022, 7:19 PMFlyteRemote
. for some context, this workflow was created by copying over the PythonFunctionWorkflow
and it redefines the workflow's module and name. details in 🧵FlyteRemote
is this
KeyError(resource_type: LAUNCH_PLAN
project: "sp-one-model"
domain: "staging"
name: "onemodel.models.subscribers.onemodel"
version: "2eb9f303-a29e-42e7-909f-21ea0916e56c"
)
where the stacktrace is
File "/Users/sharong/repo/jasper-api/backend/jasper_api/routes.py", line 235, in execute
lp = remote.fetch_launch_plan(project, domain, workflow, version)
File "/Users/sharong/.pyenv/versions/3.7.4/envs/jasper-api/lib/python3.7/site-packages/flytekit/remote/remote.py", line 443, in fetch_launch_plan
workflow = self.fetch_workflow(wf_id.project, wf_id.domain, wf_id.name, wf_id.version)
File "/Users/sharong/.pyenv/versions/3.7.4/envs/jasper-api/lib/python3.7/site-packages/flytekit/remote/remote.py", line 414, in fetch_workflow
return FlyteWorkflow.promote_from_closure(compiled_wf, node_launch_plans)
File "/Users/sharong/.pyenv/versions/3.7.4/envs/jasper-api/lib/python3.7/site-packages/flytekit/remote/workflow.py", line 159, in promote_from_closure
tasks=tasks,
File "/Users/sharong/.pyenv/versions/3.7.4/envs/jasper-api/lib/python3.7/site-packages/flytekit/remote/workflow.py", line 106, in promote_from_model
for node in base_model_non_system_nodes
File "/Users/sharong/.pyenv/versions/3.7.4/envs/jasper-api/lib/python3.7/site-packages/flytekit/remote/workflow.py", line 106, in <dictcomp>
for node in base_model_non_system_nodes
File "/Users/sharong/.pyenv/versions/3.7.4/envs/jasper-api/lib/python3.7/site-packages/flytekit/remote/nodes.py", line 89, in promote_from_model
tasks,
File "/Users/sharong/.pyenv/versions/3.7.4/envs/jasper-api/lib/python3.7/site-packages/flytekit/remote/component_nodes.py", line 119, in promote_from_model
tasks=tasks,
File "/Users/sharong/.pyenv/versions/3.7.4/envs/jasper-api/lib/python3.7/site-packages/flytekit/remote/workflow.py", line 106, in promote_from_model
for node in base_model_non_system_nodes
File "/Users/sharong/.pyenv/versions/3.7.4/envs/jasper-api/lib/python3.7/site-packages/flytekit/remote/workflow.py", line 106, in <dictcomp>
for node in base_model_non_system_nodes
File "/Users/sharong/.pyenv/versions/3.7.4/envs/jasper-api/lib/python3.7/site-packages/flytekit/remote/nodes.py", line 89, in promote_from_model
tasks,
File "/Users/sharong/.pyenv/versions/3.7.4/envs/jasper-api/lib/python3.7/site-packages/flytekit/remote/component_nodes.py", line 108, in promote_from_model
base_model.launchplan_ref, node_launch_plans[base_model.launchplan_ref]
lhs
and location
were not defined. it seems like lhs
needs to be defined - can you elaborate on what the attribute is for and how it's defined?Yee
Sharon Gong
04/14/2022, 7:57 PMflytekit==0.23.0
and i've also tried flytekit==0.25.0
remote = FlyteRemote.from_config(config_file_path='flyte.config')
lp = remote.fetch_launch_plan(project, domain, workflow, version)
Dylan Wilder
04/14/2022, 9:30 PM->
translates to invokes as in wf_b is a subworkflow of a.Yee
Dylan Wilder
04/14/2022, 9:38 PMYee
Dylan Wilder
04/14/2022, 9:39 PMYee
Dylan Wilder
04/19/2022, 2:58 PMYee