incalculable-ice-13425
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/dataincalculable-ice-13425
08/03/2023, 2:02 PMthankful-minister-83577
thankful-minister-83577
incalculable-ice-13425
08/03/2023, 4:43 PMincalculable-ice-13425
08/03/2023, 4:44 PMtall-lock-23197
incalculable-ice-13425
08/04/2023, 6:41 AMaverage-school-71780
03/06/2024, 10:45 AM