Can I parameterize checkpointing at the task level?
with Flow('foo') as f:
chck = Parameter('checkpointing') # Let's say we pass in False
do_stuff = task(some_python_callable, checkpoint=chck)()
04/20/2022, 9:25 PM
I think the answer here is not at all as that is handled at registration. You need to use the result interface inside the task to get that flexibility, and then you can parameterize whether or not to save
04/20/2022, 9:26 PM
gotcha thanks for clarifying i figured i was oversimplifying 😄