freezing-shampoo-67249
11/29/2022, 4:04 PM@task()
def download_data() -> FlyteDirectory:
working_dir = flytekit.current_context().working_directory
download_to_working_dir()
# now data is in "working_dir"
return FlyteDirectory(path=working_dir)
@task()
def train(data_dir: FlyteDirectory): -> None
train_model(data_dir=data_dir) # reads files from disk and trains model
limited-dog-47035
11/29/2022, 4:25 PMThe source path that users are expected to call open() on
You can use FlyteFile also https://docs.flyte.org/projects/flytekit/en/latest/types.builtins.file.htmlfreezing-shampoo-67249
11/30/2022, 10:44 AMlimited-dog-47035
11/30/2022, 3:06 PMfreezing-shampoo-67249
12/01/2022, 3:24 PM