Ailin Yu
11/30/2022, 6:39 PMList[Type]
where the Type
is complex? Or maybe I’m just specifying my input incorrectly: I specifically have a workflow with an input List[FlyteFile]
that is passing that input to task that takes a List[FlyteFile]
. When I try to run this workflow through the Flyte UI, passing an input like ["test_file.txt"]
and the workflow starts running, the UI shows that this was my input:
{
"test_list": [
"(empty)"
]
}
So as you can imagine, the workflow then fails to run:
Message:
Cannot convert from scalar {
none_type {
}
}
to <class 'flytekit.types.file.file.FlyteFile'>
SYSTEM ERROR! Contact platform administrators.
(More details in thread)hello_world
one slightly:
@task
def say_hello(test_list: List[FlyteFile]) -> str:
return "hello world
@workflow
def my_wf(test_list: List[FlyteFile]) -> str:
res = say_hello(test_list=test_list)
return res
And then registered:
pyflyte -c ~/.flyte/config-sandbox.yaml register --version ref2 core/flyte_basics/hello_world.py
Jay Ganbat
11/30/2022, 6:55 PMAilin Yu
11/30/2022, 7:03 PMKevin Su
11/30/2022, 7:15 PM[{
"dimensionality": 0,
"uri": "<s3://bucket/test_file.txt>"
}]
"dimensionality": 0
means it’s a blob fileAilin Yu
11/30/2022, 7:41 PMJay Ganbat
11/30/2022, 7:43 PM1
is for FlyteDirectoryKevin Su
11/30/2022, 7:43 PMDan Rammer (hamersaw)
11/30/2022, 11:14 PMKevin Su
11/30/2022, 11:23 PM