acoustic-carpenter-78188
06/25/2024, 6:32 AMuri
of the input will be like /var/.....
. This will cause an error as the remote entity couldn't access the local file.
My python file:
from flytekit import task, workflow
from typing import Any
@task()
def t1(a: Any) -> int:
if type(a) == int:
return a + 1
return 0
@workflow()
def wf1(a: Any) -> int:
return t1(a=a)
Error Message:
FileNotFoundError: Failed to convert inputs of task '<file_name>.t1':
[Errno 2] No such file or directory: '/var/folders/bl/kvjgvw0n5dddmglqdwy4zmpw0000gn/T/flyte-dlkg2l19/raw/2c9421ed6fd50ff5693cd38840c39c48/57b865dff2967bb348047887fad8262c'
Expected behavior
Similar to FlyteFile, Flytekit should upload the data to s3 so that the data will be accessible to the workflow & task.
image
Image provided by @Future-Outlier
Additional context to reproduce
No response
Screenshots
image
Are you sure this issue hasn't been raised already?
☑︎ Yes
Have you read the Code of Conduct?
☑︎ Yes
flyteorg/flyteacoustic-carpenter-78188
06/25/2024, 6:32 AM