cool-lifeguard-49380
07/07/2023, 4:01 PMmessage: "Could not find LHS for WorkflowBase - racon.torch.flyte.common_workflows.default_conversion && Inputs (4): {'model_uri': <class 'str'>, 'kd_task_uri': <class 'str'>, 'config': <class 'racon.torch.flyte.common_workflows.DefaultConfig'>, 'dry_run': <class 'bool'>} && Outputs (1): {'o0': <class 'str'>} && Output bindings: [<FlyteLiteral var: "o0" binding { promise { node_id: "dn4" var: "o0" } }>] && in __main__"
name: "flytekit"
We are lost trying to figure out what is going wrong.
Thanks πcool-lifeguard-49380
07/07/2023, 4:01 PM@dynamic
(potentially a bad idea?)glamorous-carpet-83516
07/07/2023, 4:16 PMcool-lifeguard-49380
07/07/2023, 4:17 PMglamorous-carpet-83516
07/07/2023, 4:18 PM@task
...
if __name__ == "__main__":
@dataclass # dataclass can't be defined here or in the function
...
glamorous-carpet-83516
07/07/2023, 4:18 PMcool-lifeguard-49380
07/07/2023, 4:21 PMcool-lifeguard-49380
07/07/2023, 4:25 PMthankful-minister-83577
thankful-minister-83577
straight-jewelry-34587
07/10/2023, 8:38 AMworkflow.py
. I assume it is very much related with that we pass tasks as arguments to a dynamic task by converting it to a string and using importlib to load it again.straight-jewelry-34587
07/10/2023, 8:39 AMthankful-minister-83577
straight-jewelry-34587
07/10/2023, 3:45 PM@dynamic
def main_with_task() -> str:
from flyte_tasks.tasks import train_task
new_model = train_task(model1="model")
return new_model
Thank you π