Flyte Team, I have been working on using
FlyteRemote
and now I understand how to ask my question lol. My remote workflow looks like this:
@dataclass_json
@dataclass
class WrappedList:
s: str
@flytekit.workflow
def count_files_test_workflow(
in: WrappedList,
):
How do I call this workflow with
FlyteRemote
? If I try to do:
remote = FlyteRemote(...)
lp = remote.fetch_launch_plan(...)
remote.execute(lp, inputs={'in': WrappedList("foo")})
Then I get
FlyteTypeException: Type error! Received: <class '__main__.WrappedList'> with value: WrappedList(s='foo'), Expected: <class 'types.WrappedlistSchema'>
. I looked into the
type_hints
argument to
remote.execute
, but I don't think that's the right thing here. What I really need to be able to do is specify
inputs={'in': x}
where x is an instance of types.WrappedListSchema.