An Hoang
12/12/2021, 4:48 PMtarget
keyword argument for all tasks at flow level? I have some tasks with target
caching and for testing I would like all the result files to be created again without caching. If we can selectively decide which one to override for a particular run that would be even betterAnna Geller
An Hoang
12/12/2021, 5:33 PMAn Hoang
12/12/2021, 5:35 PMAn Hoang
12/12/2021, 5:37 PMKevin Kho
@task(checkpoint=True, target="...")
def abc(x):
return x+1
def make_flow():
with Flow(...) as flow:
return flow
if debug:
abc.checkpoint=False
abc.target=None
flow = make_flow()
flow.run()
else:
flow = make_flow()
flow.register(...)