shy-accountant-549
@task def t1() -> FlyteFile: # do something and save checkpoint to path/to/file return FlyteFile("path/to/file") def t2(input: FlyteFile) -> float: checkpoint = torch.load(input) # do something return 1.0 @workflow def wf() -> float: t1_output = t1() return t2(t1_output)
[Errno 2] No such file or directory: '/tmp/flytemlfm4mk1/local_flytekit/0569821759669848f705b8863309a4bb/checkpoint-epoch0001.pth'
gray-ocean-62145
def t2(input: FlyteFile) -> float: input_path = input.download() checkpoint = torch.load(input_path) # do something return 1.0
Flyte enables production-grade orchestration for machine learning workflows and data processing created to accelerate local workflows to production.