Pradithya Aria Pura
03/20/2023, 7:32 AMFlyteDirectory
and output the same FlyteDirectory
. Is it possible to force all the FlyteDirectory
to be backed by the same GCS path? Essentially sharing a directory content across tasks.
@task
def task(work_dir: FlyteDirectory) -> FlyteDirectory:
# do something in work_dir
# potentially add files
return work_dir
@workflow
def workflow():
work_dir = init_workdir()
work_dir = task(work_dir)
work_dir = task(work_dir)
work_dir = task(work_dir)
Ketan (kumare3)
Pradithya Aria Pura
03/21/2023, 3:25 AM