Gaurav Kumar
08/03/2023, 1:36 PMtask2 = ContainerTask(
name="task2",
input_data_dir="/var/inputs",
output_data_dir="/var/outputs",
inputs=kwtypes(data=FlyteDirectory),
outputs=kwtypes(out=FlyteDirectory),
image="task2-image....",
command=[...],
arguments=[...]
)
@task
def task1() -> FlyteDirectory:
...
@workflow
def aeb_sanity_workflow() -> FlyteDirectory:
data = task1()
ans = task2(data=data)
Just to check the functionality of FlyteDirectory, I tried creating another task3 which is normal python task which can take this FlyteDirectory as input, and iterate over that using os.listdir
. I’m able to see the files in this task.
What exactly I need to do in ContainerTask so that FlyteDirectory content could be seen at /var/inputs/data
Yee
Gaurav Kumar
08/03/2023, 4:43 PMSamhita Alla
Gaurav Kumar
08/04/2023, 6:41 AM