Hey there,I have a package I've developed that contains a module which exposes most of the functionality of the package wrapped as FunctionTasks. Its not clear to me how I can add retries to a task that was not defined with the
decorator when mapping:
import culvert.tasks as ct
with Flow("some flow") as f:
<some other task>
copy_batches_local = ct.copy_batch_local.map(
TypeError: got an unexpected keyword argument'task_args'